diff --git a/src/ert/scheduler/scheduler.py b/src/ert/scheduler/scheduler.py index 6c3ecae448e..19e98ccac37 100644 --- a/src/ert/scheduler/scheduler.py +++ b/src/ert/scheduler/scheduler.py @@ -218,10 +218,11 @@ async def _process_event_queue(self) -> None: while True: event = await self.driver.event_queue.get() job = self._jobs[event.iens] - if not job.started.is_set(): - # Any event implies the job has at least started - job.started.set() - elif isinstance(event, FinishedEvent): + + # Any event implies the job has at least started + job.started.set() + + if isinstance(event, FinishedEvent): if event.aborted: job.returncode.cancel() else: