We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d0bff72 commit c710e08Copy full SHA for c710e08
replications/internal/queue_management_test.go
@@ -97,12 +97,14 @@ func TestEnqueueScan(t *testing.T) {
97
}
98
99
// Check queue position
100
+ // The sleep is not ideal, but we need to let the queue process some before closing it and there's not
101
+ // currently a great way to check if it has run any.
102
+ time.Sleep(50 * time.Millisecond)
103
closeRq(rq)
104
scan, err := rq.queue.NewScanner()
105
t.Cleanup(func() {
106
require.NoError(t, rq.queue.Close())
107
})
-
108
if tt.writeFuncReturn == nil {
109
require.ErrorIs(t, err, io.EOF)
110
} else {
0 commit comments