From 0752f7103299552a810ddde2745f1c8c1432f0dd Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Thu, 21 Nov 2024 02:08:39 +0530 Subject: [PATCH] fix test --- flow/e2e/test_utils.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go index c3e577a4d..7fb3f857d 100644 --- a/flow/e2e/test_utils.go +++ b/flow/e2e/test_utils.go @@ -221,7 +221,7 @@ func SetupCDCFlowStatusQuery(t *testing.T, env WorkflowRun, config *protos.FlowC var status protos.FlowStatus if err := response.Get(&status); err != nil { t.Fatal(err) - } else if status == protos.FlowStatus_STATUS_RUNNING { + } else if status == protos.FlowStatus_STATUS_RUNNING || status == protos.FlowStatus_STATUS_COMPLETED { return } else if counter > 30 { env.Cancel()