diff --git a/flow/connectors/snowflake/client.go b/flow/connectors/snowflake/client.go index 59814b8512..399ec3c832 100644 --- a/flow/connectors/snowflake/client.go +++ b/flow/connectors/snowflake/client.go @@ -85,8 +85,6 @@ func (c *SnowflakeConnector) getTableCounts(ctx context.Context, tables []string } func (c *SnowflakeConnector) GetAllTables(ctx context.Context) ([]string, error) { - // return all tables in database in schema.table form - // get it from information schema columns rows, err := c.database.QueryContext(ctx, ` SELECT table_schema, table_name FROM information_schema.tables