This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new 515941209 fix(connectors): increase poll budget in fetch_rows_as to
fix flaky restart test (#3106)
515941209 is described below
commit 51594120992fde1f7a047fd4be9b09596d18cb5c
Author: Atharva Lade <[email protected]>
AuthorDate: Wed Apr 22 05:23:52 2026 -0500
fix(connectors): increase poll budget in fetch_rows_as to fix flaky restart
test (#3106)
---
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 559013d63..30e58d091 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!(
