remove redundant operation in Runner

Matgenix · Mar 5, 2024 · 19e0c8a · 19e0c8a
1 parent 555ede5
commit 19e0c8a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 7 deletions.
diff --git 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
@@ -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