remove test_monitor.py

jonathan-eq · jonathan-eq · commit bcf9998d5d5e · 2025-04-07T08:45:57.000+02:00
diff --git a/src/ert/run_models/base_run_model.py b/src/ert/run_models/base_run_model.py
@@ -558,7 +558,7 @@ async def run_ensemble_evaluator_async(
         evaluator = EnsembleEvaluator(
             ee_ensemble,
             ee_config,
-            send_to_brm=functools.partial(
+            event_handler=functools.partial(
                 self.send_snapshot_event, iteration=ensemble.iteration
             ),
         )
diff --git a/tests/ert/unit_tests/ensemble_evaluator/test_monitor.py b/tests/ert/unit_tests/ensemble_evaluator/test_monitor.py
diff --git a/tests/ert/unit_tests/ensemble_evaluator/test_scheduler.py b/tests/ert/unit_tests/ensemble_evaluator/test_scheduler.py
@@ -55,7 +55,7 @@ def create_manifest_file():
         config = EvaluatorServerConfig(use_token=False)
         events_to_brm = asyncio.Queue()
         evaluator = EnsembleEvaluator(
-            ensemble, config, send_to_brm=events_to_brm.put_nowait
+            ensemble, config, event_handler=events_to_brm.put_nowait
         )
         with caplog.at_level(logging.DEBUG):
             run_task = asyncio.create_task(

Original file line number	Diff line number	Diff line change
`@@ -558,7 +558,7 @@ async def run_ensemble_evaluator_async(`
`558`	`558`	`evaluator = EnsembleEvaluator(`
`559`	`559`	`ee_ensemble,`
`560`	`560`	`ee_config,`
`561`		`- send_to_brm=functools.partial(`
	`561`	`+ event_handler=functools.partial(`
`562`	`562`	`self.send_snapshot_event, iteration=ensemble.iteration`
`563`	`563`	`),`
`564`	`564`	`)`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ def create_manifest_file():`
`55`	`55`	`config = EvaluatorServerConfig(use_token=False)`
`56`	`56`	`events_to_brm = asyncio.Queue()`
`57`	`57`	`evaluator = EnsembleEvaluator(`
`58`		`- ensemble, config, send_to_brm=events_to_brm.put_nowait`
	`58`	`+ ensemble, config, event_handler=events_to_brm.put_nowait`
`59`	`59`	`)`
`60`	`60`	`with caplog.at_level(logging.DEBUG):`
`61`	`61`	`run_task = asyncio.create_task(`