Merge pull request #741 from twmb/test_bump

kgo: bump consumer_direct_test timeout, make non-parallel
twmb · May 26, 2024 · d1514f9 · d1514f9
2 parents aaae445 + d7a80b5
commit d1514f9
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/pkg/kgo/consumer_direct_test.go b/pkg/kgo/consumer_direct_test.go
@@ -387,8 +387,6 @@ func TestPauseIssue489(t *testing.T) {
 }
 
 func TestPauseIssueOct2023(t *testing.T) {
-	t.Parallel()
-
 	t1, cleanup1 := tmpTopicPartitions(t, 1)
 	t2, cleanup2 := tmpTopicPartitions(t, 1)
 	t3, cleanup3 := tmpTopicPartitions(t, 1)
@@ -431,7 +429,7 @@ func TestPauseIssueOct2023(t *testing.T) {
 		{"records", func(ctx context.Context) Fetches { return cl.PollRecords(ctx, 1000) }},
 	} {
 		for i := 0; i < 10; i++ {
-			ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
+			ctx, cancel := context.WithTimeout(ctx, 30*time.Second)
 			var sawt1, sawt2, sawt3 bool
 			for (!sawt1 || !sawt2 || !sawt3) && !closed(ctx.Done()) {
 				fs := pollfn.fn(ctx)