test_evaluator.py (aodh-14.0.0) | : | test_evaluator.py (aodh-15.0.0) | ||
---|---|---|---|---|
skipping to change at line 68 | skipping to change at line 68 | |||
self.useFixture(fixtures.MockPatch( | self.useFixture(fixtures.MockPatch( | |||
'aodh.storage.get_connection_from_config', | 'aodh.storage.get_connection_from_config', | |||
return_value=self._fake_conn | return_value=self._fake_conn | |||
)) | )) | |||
def _do_test_start(self, test_interval=120, | def _do_test_start(self, test_interval=120, | |||
coordination_heartbeat_interval=1.0, | coordination_heartbeat_interval=1.0, | |||
coordination_active=False): | coordination_active=False): | |||
self.CONF.set_override('evaluation_interval', | self.CONF.set_override('evaluation_interval', | |||
test_interval) | test_interval, | |||
group='evaluator') | ||||
self.CONF.set_override('heartbeat_interval', | self.CONF.set_override('heartbeat_interval', | |||
coordination_heartbeat_interval, | coordination_heartbeat_interval, | |||
group='coordination') | group='coordination') | |||
self._fake_pc.is_active.return_value = coordination_active | self._fake_pc.is_active.return_value = coordination_active | |||
svc = evaluator.AlarmEvaluationService(0, self.CONF) | svc = evaluator.AlarmEvaluationService(0, self.CONF) | |||
self.addCleanup(svc.terminate) | self.addCleanup(svc.terminate) | |||
svc.terminate() | svc.terminate() | |||
svc.partition_coordinator.start.assert_called_once_with() | svc.partition_coordinator.start.assert_called_once_with() | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 2 lines changed or added |