Skip to content

Commit 9ec46ac

Browse files
committed
test(consumer): add delay
1 parent ef52cc1 commit 9ec46ac

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

consumer_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,7 +290,7 @@ func TestHandleAllJobBeforeShutdownConsumer(t *testing.T) {
290290
assert.NoError(t, w.Shutdown())
291291
done <- struct{}{}
292292
}()
293-
293+
time.Sleep(50 * time.Millisecond)
294294
task, err := w.Request()
295295
assert.NotNil(t, task)
296296
assert.NoError(t, err)

0 commit comments

Comments
 (0)