Reset started event

equinor · Dec 14, 2023 · 6b5ec33 · 6b5ec33
1 parent 9fd4e8d
commit 6b5ec33
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/ert/scheduler/job.py b/src/ert/scheduler/job.py
@@ -92,6 +92,7 @@ async def _execute(self, sem: asyncio.BoundedSemaphore) -> None:
             else:
                 await self._send(State.FAILED)
                 self.returncode = asyncio.Future()
+                self.started = asyncio.Event()
 
         except asyncio.CancelledError:
             await self._send(State.ABORTING)
@@ -109,8 +110,9 @@ async def __call__(
 
         for _ in range(max_submit):
             await self._execute(sem)
-            # job has succesfully finished, no need to retry
-            if self.returncode.done():
+            # job has succesfully finished or was aborted
+            # no need to retry
+            if self.returncode.done() or self.aborted.is_set():
                 break
             else:
                 message = f"Realization: {self.iens} failed, resubmitting"