Make sure job_queue will not timeout when sending event

xjules · Aug 25, 2023 · 98d3465 · 98d3465
1 parent a0e1259
commit 98d3465
Showing 1 changed file with 6 additions and 1 deletion.
diff --git 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(