From 6e552f6d13b3433ab9e402edeb9c25c9c02763af Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Tue, 14 Nov 2023 16:20:29 -0500 Subject: [PATCH] fix things --- flow/connectors/snowflake/qrep_avro_sync.go | 4 +++- flow/e2e/snowflake/qrep_flow_sf_test.go | 5 ++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/flow/connectors/snowflake/qrep_avro_sync.go b/flow/connectors/snowflake/qrep_avro_sync.go index 366c49887f..e74d0fdb2f 100644 --- a/flow/connectors/snowflake/qrep_avro_sync.go +++ b/flow/connectors/snowflake/qrep_avro_sync.go @@ -339,7 +339,9 @@ func (s *SnowflakeAvroSyncMethod) putFileToStage(localFilePath string, stage str return nil } -func (sc *SnowflakeConnector) GetCopyTransformation(dstTableName string) (*CopyInfo, error) { +func (sc *SnowflakeConnector) GetCopyTransformation( + dstTableName string, +) (*CopyInfo, error) { colInfo, colsErr := sc.getColsFromTable(dstTableName) if colsErr != nil { return nil, fmt.Errorf("failed to get columns from destination table: %w", colsErr) diff --git a/flow/e2e/snowflake/qrep_flow_sf_test.go b/flow/e2e/snowflake/qrep_flow_sf_test.go index f68321333b..82901beac2 100644 --- a/flow/e2e/snowflake/qrep_flow_sf_test.go +++ b/flow/e2e/snowflake/qrep_flow_sf_test.go @@ -41,12 +41,11 @@ func (s *PeerFlowE2ETestSuiteSF) compareTableContentsSF(tableName string, select // read rows from destination table qualifiedTableName := fmt.Sprintf("%s.%s.%s", s.sfHelper.testDatabaseName, s.sfHelper.testSchemaName, tableName) - exclude := "EXCLUDE _PEERDB_SYNCED_AT, _PEERDB_IS_DELETED" var sfSelQuery string if caseSensitive { - sfSelQuery = fmt.Sprintf(`SELECT %s %s FROM %s ORDER BY "id"`, selector, exclude, qualifiedTableName) + sfSelQuery = fmt.Sprintf(`SELECT %s FROM %s ORDER BY "id"`, selector, qualifiedTableName) } else { - sfSelQuery = fmt.Sprintf(`SELECT %s %s FROM %s ORDER BY id`, selector, exclude, qualifiedTableName) + sfSelQuery = fmt.Sprintf(`SELECT %s FROM %s ORDER BY id`, selector, qualifiedTableName) } fmt.Printf("running query on snowflake: %s\n", sfSelQuery)