projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Improved mult-processing of mon-evaluator
[osm/MON.git]
/
osm_mon
/
tests
/
unit
/
evaluator
/
test_evaluator.py
diff --git
a/osm_mon/tests/unit/evaluator/test_evaluator.py
b/osm_mon/tests/unit/evaluator/test_evaluator.py
index
43cec96
..
e7b9162
100644
(file)
--- 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()
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")
@mock.patch.object(EvaluatorService, "evaluate_alarms")
- def test_evaluate(self, evaluate_alarms,
notify_alarm, proces
s):
+ def test_evaluate(self, evaluate_alarms,
_notify_alarm, future
s):
mock_alarm = mock.Mock()
mock_alarm.operation = 'gt'
mock_alarm.threshold = 50.0
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()
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
)