diff --git a/tests/ert/unit_tests/ensemble_evaluator/ensemble_evaluator_utils.py b/tests/ert/unit_tests/ensemble_evaluator/ensemble_evaluator_utils.py index 8e64fcdf12a..d8cece2fbf3 100644 --- a/tests/ert/unit_tests/ensemble_evaluator/ensemble_evaluator_utils.py +++ b/tests/ert/unit_tests/ensemble_evaluator/ensemble_evaluator_utils.py @@ -7,10 +7,6 @@ class TestEnsemble(Ensemble): __test__ = False def __init__(self, iter_, reals, fm_steps, id_): - self.iter = iter_ - self.test_reals = reals - self.fm_steps = fm_steps - the_reals = [ Realization( real_no, diff --git a/tests/ert/unit_tests/ensemble_evaluator/test_ensemble_evaluator.py b/tests/ert/unit_tests/ensemble_evaluator/test_ensemble_evaluator.py index d22bbdf12ad..7ff6d2b4ef7 100644 --- a/tests/ert/unit_tests/ensemble_evaluator/test_ensemble_evaluator.py +++ b/tests/ert/unit_tests/ensemble_evaluator/test_ensemble_evaluator.py @@ -382,9 +382,9 @@ async def mock_receiver(self): with patch.object(Monitor, "_receiver", mock_receiver): async with Monitor(conn_info) as monitor: - await asyncio.sleep(1.0) + await asyncio.sleep(0.5) await monitor.signal_done() - # in 1 second we should receive at least 2 heartbeats + # in 0.5 second we should receive at least 2 heartbeats assert received_heartbeats > 1 @@ -393,7 +393,7 @@ async def test_dispatch_endpoint_clients_can_connect_and_monitor_can_shut_down_e evaluator_to_use, ): evaluator = evaluator_to_use - evaluator._batching_interval = 10 + evaluator._batching_interval = 0.2 evaluator._max_batch_size = 4 conn_info = evaluator._config.get_connection_info() diff --git a/tests/ert/unit_tests/ensemble_evaluator/test_monitor.py b/tests/ert/unit_tests/ensemble_evaluator/test_monitor.py index 1ee90c03743..287774ee837 100644 --- a/tests/ert/unit_tests/ensemble_evaluator/test_monitor.py +++ b/tests/ert/unit_tests/ensemble_evaluator/test_monitor.py @@ -108,7 +108,7 @@ async def test_unexpected_close_after_connection_successful( ee_con_info = EvaluatorConnectionInfo(f"tcp://127.0.0.1:{unused_tcp_port}") monkeypatch.setattr(Monitor, "DEFAULT_MAX_RETRIES", 0) - monkeypatch.setattr(Monitor, "DEFAULT_ACK_TIMEOUT", 1) + monkeypatch.setattr(Monitor, "DEFAULT_ACK_TIMEOUT", 0.5) async def mock_event_handler(router_socket): dealer, _, frame = await router_socket.recv_multipart()