fix things

PeerDB-io · Nov 14, 2023 · 6e552f6 · 6e552f6
1 parent 9ff1a16
commit 6e552f6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git 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
@@ -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)