diff --git a/src/ert/job_queue/queue.py b/src/ert/job_queue/queue.py index 33c9697cc3d..1778f772c32 100644 --- a/src/ert/job_queue/queue.py +++ b/src/ert/job_queue/queue.py @@ -289,7 +289,12 @@ async def _publish_changes( ] ) while events: - await asyncio.wait_for(ee_connection.send(to_json(events[0])), 60) + while True: + try: + await asyncio.wait_for(ee_connection.send(to_json(events[0])), 60) + break + except asyncio.TimeoutError: + pass events.popleft() async def _execution_loop_queue_via_websockets(