trying to fix pt.2

PeerDB-io · Dec 20, 2023 · 7d12f41 · 7d12f41
1 parent d138893
commit 7d12f41
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go
@@ -1287,7 +1287,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Soft_Delete_Basic() {
 	s.compareTableContentsBQ("test_softdel", "id,c1,c2,t")
 
 	newerSyncedAtQuery := fmt.Sprintf(`
-		SELECT COUNT(*) FROM %s.%s WHERE _PEERDB_IS_DELETED = TRUE`,
+		SELECT COUNT(*) FROM`+"`%s.%s`"+`WHERE _PEERDB_IS_DELETED = TRUE`,
 		s.bqHelper.datasetName, dstTableName)
 	numNewRows, err := s.bqHelper.RunIntQuery(newerSyncedAtQuery)
 	require.NoError(s.t, err)
@@ -1371,7 +1371,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Soft_Delete_IUD_Same_Batch() {
 	s.compareTableContentsBQ("test_softdel_iud", "id,c1,c2,t")
 
 	newerSyncedAtQuery := fmt.Sprintf(`
-		SELECT COUNT(*) FROM %s.%s WHERE _PEERDB_IS_DELETED = TRUE`,
+		SELECT COUNT(*) FROM`+"`%s.%s`"+`WHERE _PEERDB_IS_DELETED = TRUE`,
 		s.bqHelper.datasetName, dstTableName)
 	numNewRows, err := s.bqHelper.RunIntQuery(newerSyncedAtQuery)
 	require.NoError(s.t, err)
@@ -1459,7 +1459,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Soft_Delete_UD_Same_Batch() {
 	s.compareTableContentsBQ("test_softdel_ud", "id,c1,c2,t")
 
 	newerSyncedAtQuery := fmt.Sprintf(`
-		SELECT COUNT(*) FROM %s.%s WHERE _PEERDB_IS_DELETED = TRUE`,
+		SELECT COUNT(*) FROM`+"`%s.%s`"+`WHERE _PEERDB_IS_DELETED = TRUE`,
 		s.bqHelper.datasetName, dstTableName)
 	numNewRows, err := s.bqHelper.RunIntQuery(newerSyncedAtQuery)
 	require.NoError(s.t, err)
@@ -1535,7 +1535,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Soft_Delete_Insert_After_Delete() {
 	s.compareTableContentsBQ("test_softdel_iad", "id,c1,c2,t")
 
 	newerSyncedAtQuery := fmt.Sprintf(`
-		SELECT COUNT(*) FROM %s.%s WHERE _PEERDB_IS_DELETED = TRUE`,
+		SELECT COUNT(*) FROM`+"`%s.%s`"+`WHERE _PEERDB_IS_DELETED = TRUE`,
 		s.bqHelper.datasetName, dstTableName)
 	numNewRows, err := s.bqHelper.RunIntQuery(newerSyncedAtQuery)
 	require.NoError(s.t, err)