diff --git a/src/jobflow_remote/jobs/runner.py b/src/jobflow_remote/jobs/runner.py index 751565b5..8e0582a2 100644 --- a/src/jobflow_remote/jobs/runner.py +++ b/src/jobflow_remote/jobs/runner.py @@ -282,12 +282,6 @@ def run( self.update_batch_jobs ) - if complete: - self.advance_state(states) - scheduler.every(self.runner_options.delay_advance_status).seconds.do( - self.advance_state, states=states - ) - try: ticks_remaining: int | bool = True if ticks is not None: diff --git a/tests/integration/test_slurm.py b/tests/integration/test_slurm.py index 8edb983e..a0368eff 100644 --- a/tests/integration/test_slurm.py +++ b/tests/integration/test_slurm.py @@ -162,7 +162,7 @@ def test_job_with_callable_kwarg(worker, job_controller): submit_flow(flow, worker=worker) runner = Runner() - runner.run(ticks=10) + runner.run(ticks=12) assert job_controller.count_jobs({}) == 3 assert len(job_controller.get_jobs({})) == 3