Reset started event

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"

src/ert/scheduler/scheduler.py

@@ -127,8 +127,8 @@ async def execute(
 
             start = asyncio.Event()
             sem = asyncio.BoundedSemaphore(
-                semaphore._initial_value if semaphore else 10
-            )  # type: ignore
+                semaphore._initial_value if semaphore else 10  # type: ignore
+            )
             for iens, job in self._jobs.items():
                 self._tasks[iens] = asyncio.create_task(
                     job(start, sem, self._max_submit)