From bd73c11e0b375aa4be19557a8fa23b698dd6967b Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Sat, 2 Dec 2023 11:37:54 +0530 Subject: [PATCH] updated tests --- flow/e2e/snowflake/peer_flow_sf_test.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go index c3ac8c74a8..13fc3a51f2 100644 --- a/flow/e2e/snowflake/peer_flow_sf_test.go +++ b/flow/e2e/snowflake/peer_flow_sf_test.go @@ -1267,8 +1267,8 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Soft_Delete_Basic() { } limits := peerflow.CDCFlowLimits{ - TotalSyncFlows: 6, - MaxBatchSize: 100, + ExitAfterRecords: 3, + MaxBatchSize: 100, } // in a separate goroutine, wait for PeerFlowStatusQuery to finish setup @@ -1347,8 +1347,8 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Soft_Delete_IUD_Same_Batch() { } limits := peerflow.CDCFlowLimits{ - TotalSyncFlows: 2, - MaxBatchSize: 100, + ExitAfterRecords: 3, + MaxBatchSize: 100, } // in a separate goroutine, wait for PeerFlowStatusQuery to finish setup @@ -1430,8 +1430,8 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Soft_Delete_UD_Same_Batch() { } limits := peerflow.CDCFlowLimits{ - TotalSyncFlows: 4, - MaxBatchSize: 100, + ExitAfterRecords: 4, + MaxBatchSize: 100, } // in a separate goroutine, wait for PeerFlowStatusQuery to finish setup @@ -1516,8 +1516,8 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Soft_Delete_Insert_After_Delete() { } limits := peerflow.CDCFlowLimits{ - TotalSyncFlows: 6, - MaxBatchSize: 100, + ExitAfterRecords: 3, + MaxBatchSize: 100, } // in a separate goroutine, wait for PeerFlowStatusQuery to finish setup