From 7d12f414de4f4a81d20af18687bd121aca024ec9 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Wed, 20 Dec 2023 12:47:17 +0530 Subject: [PATCH] trying to fix pt.2 --- flow/e2e/bigquery/peer_flow_bq_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go index 80f3597fb1..d2e01949a6 100644 --- 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)