diff --git a/flow/connectors/utils/aws.go b/flow/connectors/utils/aws.go index 61268df3c8..7138144bb9 100644 --- a/flow/connectors/utils/aws.go +++ b/flow/connectors/utils/aws.go @@ -176,7 +176,7 @@ func GetAWSCredentialsProvider(ctx context.Context, connectorName string, peerCr AWS: peerCredentials.Credentials, EndpointUrl: peerCredentials.EndpointUrl, }, peerCredentials.Region) - if peerCredentials.RoleArn == nil { + if peerCredentials.RoleArn == nil || *peerCredentials.RoleArn == "" { logger.LoggerFromCtx(ctx).Info("Received AWS credentials from peer for connector: " + connectorName) return staticProvider, nil }