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 {