Skip to content

Commit

Permalink
kgo: bump consumer_direct_test timeout, make non-parallel
Browse files Browse the repository at this point in the history
Fails locally without one of these two bumps, and it's not really
important to diagnose which one is more important. My 2018? laptop is
struggling here.
  • Loading branch information
twmb committed May 26, 2024
1 parent aaae445 commit d7a80b5
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions pkg/kgo/consumer_direct_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -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)
Expand Down

0 comments on commit d7a80b5

Please sign in to comment.