From 4fc168e90238d7226e8233188bdddf6f22897960 Mon Sep 17 00:00:00 2001 From: Atharva Lade Date: Mon, 13 Apr 2026 02:33:16 -0500 Subject: [PATCH 1/2] fix(connectors): increase poll budget in fetch_rows_as to fix flaky restart test Use full DEFAULT_POLL_INTERVAL_MS (50ms) instead of dividing by 5 (10ms), matching other polling helpers. --- core/integration/tests/connectors/fixtures/postgres/sink.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/integration/tests/connectors/fixtures/postgres/sink.rs b/core/integration/tests/connectors/fixtures/postgres/sink.rs index 559013d63f..30e58d0910 100644 --- a/core/integration/tests/connectors/fixtures/postgres/sink.rs +++ b/core/integration/tests/connectors/fixtures/postgres/sink.rs @@ -80,7 +80,7 @@ impl PostgresSinkFixture { return Ok(rows); } } - sleep(Duration::from_millis(DEFAULT_POLL_INTERVAL_MS / 5)).await; + sleep(Duration::from_millis(DEFAULT_POLL_INTERVAL_MS)).await; } Err(TestBinaryError::InvalidState { message: format!( From 8e62e11055be74517abbc9c980bfef1e766b58ed Mon Sep 17 00:00:00 2001 From: Atharva Lade Date: Mon, 13 Apr 2026 19:55:25 -0500 Subject: [PATCH 2/2] ci: retrigger checks