Debugin connection error

src/_ert/forward_model_runner/client.py

@@ -97,6 +97,7 @@ async def reconnect(self) -> None:
             )
             if ack.decode() != "ACK":
                 raise ClientConnectionError("No Ack for connect")
+            print(f"{self.dispatch_id=} CONNECTED to {self.url=}")
         except asyncio.TimeoutError as exc:
             logger.warning("Failed to get acknowledgment on dealer connect!")
             self.term()

src/ert/ensemble_evaluator/monitor.py

@@ -44,6 +44,7 @@ def __init__(self, ee_con_info: "EvaluatorConnectionInfo") -> None:
         self._socket = self._zmq_context.socket(zmq.DEALER)
         self._socket.setsockopt(zmq.LINGER, 0)
         self._socket.setsockopt_string(zmq.IDENTITY, f"client-{self._id}")
+        print(f"{self._id=} wiith {ee_con_info.token=}")
         if ee_con_info.token is not None:
             client_public, client_secret = zmq.curve_keypair()
             self._socket.curve_secretkey = client_secret
@@ -137,6 +138,7 @@ async def reconnect(self) -> None:
             )
             if ack.decode() != "ACK":
                 raise asyncio.TimeoutError("No Ack for connect")
+            print(f"{self._id=} MONITOR CONNECTED")
         except asyncio.TimeoutError:
             print("NO CONNECTION")
             logger.warning(

tests/ert/unit_tests/ensemble_evaluator/ensemble_evaluator_utils.py

@@ -45,7 +45,7 @@ async def evaluate(self, config, _, __):
             cert=config.cert,
             token=config.token,
             max_retries=1,
-            dealer_name="eval_dispatch",
+            dealer_name="dispatch_eval",
         ) as dispatch:
             event = EnsembleStarted(ensemble=self.id_)
             await dispatch._send(event_to_json(event))

tests/ert/unit_tests/ensemble_evaluator/test_ensemble_evaluator.py

@@ -138,7 +138,9 @@ async def mock_done_prematurely(message, *args, **kwargs):
 @pytest.fixture(name="evaluator_to_use")
 async def evaluator_to_use_fixture(make_ee_config):
     ensemble = TestEnsemble(0, 2, 2, id_="0")
-    evaluator = EnsembleEvaluator(ensemble, make_ee_config())
+    evaluator = EnsembleEvaluator(
+        ensemble, make_ee_config(use_token=False, generate_cert=False)
+    )
     evaluator._batching_interval = 0.5  # batching can be faster for tests
     run_task = asyncio.create_task(evaluator.run_and_get_successful_realizations())
     await evaluator._server_started.wait()