diff options
Diffstat (limited to 'integrations')
| -rw-r--r-- | integrations/testlogger.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/integrations/testlogger.go b/integrations/testlogger.go index 9498ad655b..ff408b314c 100644 --- a/integrations/testlogger.go +++ b/integrations/testlogger.go @@ -121,7 +121,7 @@ func PrintCurrentTest(t testing.TB, skip ...int) func() { fmt.Fprintf(os.Stdout, "+++ %s ... still flushing after %v ...\n", t.Name(), slowFlush) } }) - if err := queue.GetManager().FlushAll(context.Background(), -1); err != nil { + if err := queue.GetManager().FlushAll(context.Background(), 2*time.Minute); err != nil { t.Errorf("Flushing queues failed with error %v", err) } timer.Stop() |