diff --git a/proc/proc.go b/proc/proc.go
index 63ddb0c3..2b2d6117 100644
--- a/proc/proc.go
+++ b/proc/proc.go
@@ -271,7 +271,7 @@ func InitializeAwsSourceEngine(ctx context.Context, name string, version string,
 				return nil, err
 			}
 
-			p := pool.New().WithContext(ctx).WithCancelOnError()
+			p := pool.New().WithContext(ctx)
 
 			for _, cfg := range configs {
 				p.Go(func(ctx context.Context) error {
diff --git a/sources/util.go b/sources/util.go
index 8e495c3d..eb7995f7 100644
--- a/sources/util.go
+++ b/sources/util.go
@@ -14,7 +14,7 @@ import (
 	"github.com/aws/aws-sdk-go-v2/aws/arn"
 	"github.com/aws/aws-sdk-go-v2/config"
 	"github.com/aws/aws-sdk-go-v2/service/sts"
-	awshttp "github.com/aws/smithy-go/transport/http"
+	awsHttp "github.com/aws/smithy-go/transport/http"
 	"github.com/overmindtech/discovery"
 	"github.com/overmindtech/sdp-go"
 	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
@@ -114,7 +114,7 @@ func ParseARN(arnString string) (*ARN, error) {
 
 // WrapAWSError Wraps an AWS error in the appropriate SDP error
 func WrapAWSError(err error) *sdp.QueryError {
-	var responseErr *awshttp.ResponseError
+	var responseErr *awsHttp.ResponseError
 
 	if errors.As(err, &responseErr) {
 		// If the input is bad, access is denied, or the thing wasn't found then