From 76fcb2f6b3c1e20d1b822cb3d35d1ccbf361712a Mon Sep 17 00:00:00 2001 From: TP Honey Date: Wed, 2 Oct 2024 10:16:48 +0100 Subject: [PATCH] (fix) allow all configs to run in InitializeAwsSourceEngine --- proc/proc.go | 2 +- sources/util.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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