From 577690c9736e2acb368453be05ec6a334fe0c21c Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Sat, 9 Mar 2024 01:41:01 +0530 Subject: [PATCH] remove logs --- flow/connectors/snowflake/snowflake.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index 5bea55a254..396ae48698 100644 --- a/flow/connectors/snowflake/snowflake.go +++ b/flow/connectors/snowflake/snowflake.go @@ -128,7 +128,6 @@ func TableCheck(ctx context.Context, database *sql.DB, schemaName string) error }() if !schemaExists.Valid || !schemaExists.Bool { - slog.Info("Apparently schema " + schemaName + " doesn't exist") // create schema _, err = tx.ExecContext(ctx, fmt.Sprintf(createSchemaSQL, schemaName)) if err != nil { @@ -190,7 +189,6 @@ func NewSnowflakeConnector( return nil, fmt.Errorf("failed to get DSN from Snowflake config: %w", err) } - fmt.Println(snowflakeConfig) database, err := sql.Open("snowflake", snowflakeConfigDSN) if err != nil { return nil, fmt.Errorf("failed to open connection to Snowflake peer: %w", err)