From bcf7d892637a8d0d564a400a6975ab539636a714 Mon Sep 17 00:00:00 2001 From: xjules Date: Fri, 22 Mar 2024 17:24:05 +0100 Subject: [PATCH] Fix for dispatchers queue creation --- src/ert/ensemble_evaluator/evaluator_async.py | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/src/ert/ensemble_evaluator/evaluator_async.py b/src/ert/ensemble_evaluator/evaluator_async.py index 93d0f795a37..eaec8692388 100644 --- a/src/ert/ensemble_evaluator/evaluator_async.py +++ b/src/ert/ensemble_evaluator/evaluator_async.py @@ -70,7 +70,7 @@ def __init__(self, ensemble: Ensemble, config: EvaluatorServerConfig, iter_: int self._done: asyncio.Future[bool] = asyncio.Future() self._clients: Set[WebSocketServerProtocol] = set() - self._dispatchers_connected: Optional[asyncio.Queue[None]] = None + self._dispatchers_connected: Optional[asyncio.Queue[None]] = asyncio.Queue() self._events: asyncio.Queue[CloudEvent] = asyncio.Queue() self._messages: asyncio.Queue[str] = asyncio.Queue() @@ -269,11 +269,6 @@ async def handle_client( @asynccontextmanager async def count_dispatcher(self) -> AsyncIterator[None]: - # do this here (not in __init__) to ensure the queue - # is created on the right event-loop - if self._dispatchers_connected is None: - self._dispatchers_connected = asyncio.Queue() - await self._dispatchers_connected.put(None) yield await self._dispatchers_connected.get()