diff --git a/test/integration/interrupt_resume_test.rb b/test/integration/interrupt_resume_test.rb index 72d078f6..718231e7 100644 --- a/test/integration/interrupt_resume_test.rb +++ b/test/integration/interrupt_resume_test.rb @@ -131,6 +131,7 @@ def test_interrupt_resume_inline_verifier_with_datawriter ghostferry.on_status(Ghostferry::Status::AFTER_ROW_COPY) do batches_written += 1 if batches_written >= 2 + sleep 0.1 ghostferry.term_and_wait_for_exit end end