fix(clickhouse): s3 validation - add forward slash

flow/connectors/clickhouse/clickhouse.go

@@ -8,6 +8,7 @@ import (
 	"fmt"
 	"net/url"
 	"os"
+	"strings"
 
 	"github.com/ClickHouse/clickhouse-go/v2"
 	_ "github.com/ClickHouse/clickhouse-go/v2/lib/driver"
@@ -43,9 +44,14 @@ func ValidateS3(ctx context.Context, creds *utils.ClickHouseS3Credentials) error
 		return fmt.Errorf("failed to create S3 bucket and prefix: %w", err)
 	}
 
+	prefix := object.Prefix
+	if !strings.HasSuffix(prefix, "/") {
+		prefix += "/"
+	}
+
 	_, listErr := s3Client.ListObjectsV2(ctx, &s3.ListObjectsV2Input{
 		Bucket: &object.Bucket,
-		Prefix: &object.Prefix,
+		Prefix: &prefix,
 	},
 	)
 	if listErr != nil {

flow/connectors/utils/aws.go

@@ -159,12 +159,12 @@ func GetAWSCredentialsProvider(ctx context.Context, connectorName string, peerCr
 		if err != nil {
 			return nil, err
 		}
-		logger.LoggerFromCtx(ctx).Info("Received AWS credentials with role from peer for connector: %s" + connectorName)
+		logger.LoggerFromCtx(ctx).Info("Received AWS credentials with role from peer for connector: " + connectorName)
 		return NewConfigBasedAWSCredentialsProvider(awsConfig), nil
 	}
 	envCredentialsProvider := LoadPeerDBAWSEnvConfigProvider(connectorName)
 	if envCredentialsProvider != nil {
-		logger.LoggerFromCtx(ctx).Info("Received AWS credentials from PeerDB Env for connector: %s" + connectorName)
+		logger.LoggerFromCtx(ctx).Info("Received AWS credentials from PeerDB Env for connector: " + connectorName)
 		return envCredentialsProvider, nil
 	}
 
@@ -174,7 +174,7 @@ func GetAWSCredentialsProvider(ctx context.Context, connectorName string, peerCr
 	if err != nil {
 		return nil, err
 	}
-	logger.LoggerFromCtx(ctx).Info("Received AWS credentials from SDK config for connector: %s" + connectorName)
+	logger.LoggerFromCtx(ctx).Info("Received AWS credentials from SDK config for connector: " + connectorName)
 	return NewConfigBasedAWSCredentialsProvider(awsConfig), nil
 }