db2: increase streaming test timeout from 2m to 4m for slow asnccmd reinit

emaxerrno · claude · emaxerrno · commit 6d31e85d9cb7 · 2026-05-19T08:25:33.000-07:00
Co-Authored-By: Claude Sonnet 4.6 &lt;noreply@anthropic.com&gt;
diff --git a/internal/impl/db2/integration_test.go b/internal/impl/db2/integration_test.go
@@ -383,11 +383,12 @@ db2_cdc:
 	}
 
 	// Wait for streaming rows (5 snapshot + 5 streaming = 10 total).
+	// asnccmd reinit can take >2 minutes on slow machines, so allow 4 minutes.
 	assert.Eventually(t, func() bool {
 		receivedMu.Lock()
 		defer receivedMu.Unlock()
 		return len(received) >= 10
-	}, 2*time.Minute, 500*time.Millisecond, "streaming: expected at least 10 events total")
+	}, 4*time.Minute, 500*time.Millisecond, "streaming: expected at least 10 events total")
 }
 
 // asncapPID returns the PID of the running asncap process for TESTDB, or "none".

Original file line number	Diff line number	Diff line change
`@@ -383,11 +383,12 @@ db2_cdc:`
`383`	`383`	`}`
`384`	`384`
`385`	`385`	`// Wait for streaming rows (5 snapshot + 5 streaming = 10 total).`
	`386`	`+ // asnccmd reinit can take >2 minutes on slow machines, so allow 4 minutes.`
`386`	`387`	`assert.Eventually(t, func() bool {`
`387`	`388`	`receivedMu.Lock()`
`388`	`389`	`defer receivedMu.Unlock()`
`389`	`390`	`return len(received) >= 10`
`390`		`- }, 2time.Minute, 500time.Millisecond, "streaming: expected at least 10 events total")`
	`391`	`+ }, 4time.Minute, 500time.Millisecond, "streaming: expected at least 10 events total")`
`391`	`392`	`}`
`392`	`393`
`393`	`394`	`// asncapPID returns the PID of the running asncap process for TESTDB, or "none".`