Skip to content

Commit a08b581

Browse files
famartingJoshVanL
andauthored
Update tests/worker_test.go
Co-authored-by: Josh van Leeuwen <[email protected]> Signed-off-by: Fabian Martinez <[email protected]>
1 parent 667bfff commit a08b581

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

tests/worker_test.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -136,11 +136,7 @@ func Test_TryProcessSingleOrchestrationWorkItem_Idempotency(t *testing.T) {
136136
worker := backend.NewOrchestrationWorker(be, ex, logger, backend.WithMaxParallelism(1))
137137
worker.Start(ctx)
138138

139-
require.EventuallyWithT(t, func(collect *assert.CollectT) {
140-
if !completed.Load() {
141-
collect.Errorf("process next not called CompleteOrchestrationWorkItem yet")
142-
}
143-
}, 2*time.Second, 100*time.Millisecond)
139+
require.Eventually(t, completed.Load, 2*time.Second, 10*time.Millisecond)
144140

145141
worker.StopAndDrain()
146142

0 commit comments

Comments
 (0)