diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go index 8472a3a855..32113fb456 100644 --- a/flow/connectors/s3/s3.go +++ b/flow/connectors/s3/s3.go @@ -98,7 +98,7 @@ func (c *S3Connector) Close() error { return nil } -func ValidCheck(s3Client *s3.S3, bucketUrl string, metadataDB *metadataStore.PostgresMetadataStore) error { +func ValidCheck(s3Client *s3.S3, bucketURL string, metadataDB *metadataStore.PostgresMetadataStore) error { _, listErr := s3Client.ListBuckets(nil) if listErr != nil { return fmt.Errorf("failed to list buckets: %w", listErr) @@ -106,7 +106,7 @@ func ValidCheck(s3Client *s3.S3, bucketUrl string, metadataDB *metadataStore.Pos reader := strings.NewReader(time.Now().Format(time.RFC3339)) - bucketPrefix, parseErr := utils.NewS3BucketAndPrefix(bucketUrl) + bucketPrefix, parseErr := utils.NewS3BucketAndPrefix(bucketURL) if parseErr != nil { return fmt.Errorf("failed to parse bucket url: %w", parseErr) }