X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Ftests%2Funit%2Fevaluator%2Ftest_evaluator.py;h=e7b91623837b3c850c24fa33eb75382c36f456dc;hb=da86adfc1768bdf259eed467334947b64e5d902f;hp=43cec962ebbd77f2a33ef35b4c45da4d979c8b8d;hpb=8c43ba0ce4a3910a350e3e74fe24770f04918f1e;p=osm%2FMON.git diff --git a/osm_mon/tests/unit/evaluator/test_evaluator.py b/osm_mon/tests/unit/evaluator/test_evaluator.py index 43cec96..e7b9162 100644 --- a/osm_mon/tests/unit/evaluator/test_evaluator.py +++ b/osm_mon/tests/unit/evaluator/test_evaluator.py @@ -36,10 +36,10 @@ class EvaluatorTest(TestCase): super().setUp() self.config = Config() - @mock.patch('multiprocessing.Process') - @mock.patch.object(Evaluator, "notify_alarm") + @mock.patch('concurrent.futures.ProcessPoolExecutor.submit') + @mock.patch.object(Evaluator, "_notify_alarm") @mock.patch.object(EvaluatorService, "evaluate_alarms") - def test_evaluate(self, evaluate_alarms, notify_alarm, process): + def test_evaluate(self, evaluate_alarms, _notify_alarm, futures): mock_alarm = mock.Mock() mock_alarm.operation = 'gt' mock_alarm.threshold = 50.0 @@ -48,4 +48,4 @@ class EvaluatorTest(TestCase): evaluator = Evaluator(self.config) evaluator.evaluate() - process.assert_called_with(target=notify_alarm, args=(mock_alarm, AlarmStatus.ALARM)) + futures.assert_called_with(Evaluator._notify_alarm, self.config, mock_alarm, AlarmStatus.ALARM)