From 04cf8c8d9816f332b160b48961822bdd687588ea Mon Sep 17 00:00:00 2001 From: lwolczynski Date: Mon, 25 Nov 2024 15:40:37 -0600 Subject: [PATCH] IWF-163: Add previously removed sleeps --- integ/timer_test.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/integ/timer_test.go b/integ/timer_test.go index 3c7ab159..35681e1e 100644 --- a/integ/timer_test.go +++ b/integ/timer_test.go @@ -130,6 +130,7 @@ func doTestTimerWorkflow(t *testing.T, backendType service.BackendType, config * }).Execute() panicAtHttpError(err, httpResp) + time.Sleep(time.Second * 1) timerInfos = service.GetCurrentTimerInfosQueryResponse{} err = uclient.QueryWorkflow(context.Background(), &timerInfos, wfId, "", service.GetCurrentTimerInfosQueryType) if err != nil { @@ -138,6 +139,7 @@ func doTestTimerWorkflow(t *testing.T, backendType service.BackendType, config * timer2.Status = service.TimerSkipped assertTimerQueryResponseEqual(assertions, expectedTimerInfos, timerInfos) + time.Sleep(time.Second * 1) httpResp, err = req3.WorkflowSkipTimerRequest(iwfidl.WorkflowSkipTimerRequest{ WorkflowId: wfId, WorkflowStateExecutionId: "S1-1", @@ -145,6 +147,7 @@ func doTestTimerWorkflow(t *testing.T, backendType service.BackendType, config * }).Execute() panicAtHttpError(err, httpResp) + time.Sleep(time.Second * 1) timerInfos = service.GetCurrentTimerInfosQueryResponse{} err = uclient.QueryWorkflow(context.Background(), &timerInfos, wfId, "", service.GetCurrentTimerInfosQueryType) if err != nil {