Skip to content

Commit

Permalink
IWF-163: Add previously removed sleeps
Browse files Browse the repository at this point in the history
  • Loading branch information
lwolczynski committed Nov 25, 2024
1 parent bc8cc12 commit 04cf8c8
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions integ/timer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand All @@ -138,13 +139,15 @@ 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",
TimerCommandIndex: iwfidl.PtrInt32(2),
}).Execute()
panicAtHttpError(err, httpResp)

time.Sleep(time.Second * 1)
timerInfos = service.GetCurrentTimerInfosQueryResponse{}
err = uclient.QueryWorkflow(context.Background(), &timerInfos, wfId, "", service.GetCurrentTimerInfosQueryType)
if err != nil {
Expand Down

0 comments on commit 04cf8c8

Please sign in to comment.