test(sources/s3): fix missing region error (#4131)

Juneezee · web-flow · commit 90190deac642 · 2025-05-08T12:58:35.000-07:00
Fixes: 5f56550 ("feat(sources/s3): migrate to AWS SDK v2 (#4069)") Signed-off-by: Eng Zer Jun <engzerjun@gmail.com>
diff --git a/pkg/sources/s3/s3.go b/pkg/sources/s3/s3.go
@@ -158,7 +158,7 @@ func (s *Source) newClient(ctx context.Context, region, roleArn string) (*s3.Cli
 
 	if roleArn != "" {
 		// The config loaded here will be used to retrieve and refresh temporary credentials from AssumeRole
-		cfg, err := config.LoadDefaultConfig(ctx, config.WithCredentialsProvider(credsProvider))
+		cfg, err := config.LoadDefaultConfig(ctx, config.WithRegion(region), config.WithCredentialsProvider(credsProvider))
 		if err != nil {
 			return nil, err
 		}

Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,7 @@ func (s Source) newClient(ctx context.Context, region, roleArn string) (s3.Cli`
`158`	`158`
`159`	`159`	`if roleArn != "" {`
`160`	`160`	`// The config loaded here will be used to retrieve and refresh temporary credentials from AssumeRole`
`161`		`- cfg, err := config.LoadDefaultConfig(ctx, config.WithCredentialsProvider(credsProvider))`
	`161`	`+ cfg, err := config.LoadDefaultConfig(ctx, config.WithRegion(region), config.WithCredentialsProvider(credsProvider))`
`162`	`162`	`if err != nil {`
`163`	`163`	`return nil, err`
`164`	`164`	`}`