diff --git a/producer_test.go b/producer_test.go index c03bd766..ba6d3665 100644 --- a/producer_test.go +++ b/producer_test.go @@ -124,7 +124,7 @@ func Test_Producer_CanSafelyCompleteJobsWhileFetchingNewOnes(t *testing.T) { params[i] = (*riverdriver.JobInsertFastParams)(insertParams) } - ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) + ctx, cancel := context.WithTimeout(context.Background(), 45*time.Second) t.Cleanup(cancel) go func() {