diff --git a/test/integration/interrupt_resume_test.rb b/test/integration/interrupt_resume_test.rb index 72d078f6..d60b8773 100644 --- a/test/integration/interrupt_resume_test.rb +++ b/test/integration/interrupt_resume_test.rb @@ -130,7 +130,7 @@ def test_interrupt_resume_inline_verifier_with_datawriter batches_written = 0 ghostferry.on_status(Ghostferry::Status::AFTER_ROW_COPY) do batches_written += 1 - if batches_written >= 2 + if batches_written >= 5 ghostferry.term_and_wait_for_exit end end