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!(