From 0a5cd3b5cdc29e6589219b08057ccb46c543eed3 Mon Sep 17 00:00:00 2001 From: xjules Date: Mon, 16 Dec 2024 16:16:27 +0100 Subject: [PATCH] Make sure that empty flags are set --- src/ert/ensemble_evaluator/evaluator.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/ert/ensemble_evaluator/evaluator.py b/src/ert/ensemble_evaluator/evaluator.py index 30915aa6c9f..a1344342851 100644 --- a/src/ert/ensemble_evaluator/evaluator.py +++ b/src/ert/ensemble_evaluator/evaluator.py @@ -69,8 +69,10 @@ def __init__(self, ensemble: Ensemble, config: EvaluatorServerConfig): self._server_started: asyncio.Event = asyncio.Event() self._clients_connected: set[bytes] = set() self._clients_empty: asyncio.Event = asyncio.Event() + self._clients_empty.set() self._dispatchers_connected: set[bytes] = set() self._dispatchers_empty: asyncio.Event = asyncio.Event() + self._dispatchers_empty.set() async def _publisher(self) -> None: await self._server_started.wait()