Speed up batching of events in evaluator

asyncio wait_for used in evaluator is "slow" in performance when dealing with O(100K) events in the event queue.
Therefore the suggestion is to replace it with direct fetching (via get_nowait())
and instead just sleep whenever the event queue is empty.

Co-authored-by: Lars Evje <[email protected]>

src/ert/ensemble_evaluator/evaluator.py

@@ -131,11 +131,12 @@ def set_event_handler(event_types: set[type[Event]], func: Any) -> None:
             ):
                 self._complete_batch.clear()
                 try:
-                    event = await asyncio.wait_for(self._events.get(), timeout=0.1)
+                    event = self._events.get_nowait()
                     function = event_handler[type(event)]
                     batch.append((function, event))
                     self._events.task_done()
-                except TimeoutError:
+                except asyncio.QueueEmpty:
+                    await asyncio.sleep(0.1)
                     continue
             self._complete_batch.set()
             await self._batch_processing_queue.put(batch)
@@ -381,7 +382,7 @@ async def _monitor_and_handle_tasks(self) -> None:
                     raise task_exception
                 elif task.get_name() == "server_task":
                     return
-                elif task.get_name() == "ensemble_task" or task.get_name() in {
+                elif task.get_name() in {
                     "ensemble_task",
                     "listener_task",
                 }: