X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fevaluator%2Fevaluator.py;h=0b4efdee44ea6e956cd29f59cceb12b5704243e0;hb=d97da1bc71a4a281cd62fe433fffe1fc1b9fdac6;hp=8d4c2767a91281acad96c2cacb3c060c91a50d78;hpb=7023a2f71c3374cbe3cece0ac0798a80e7fc5fd4;p=osm%2FMON.git diff --git a/osm_mon/evaluator/evaluator.py b/osm_mon/evaluator/evaluator.py index 8d4c276..0b4efde 100644 --- a/osm_mon/evaluator/evaluator.py +++ b/osm_mon/evaluator/evaluator.py @@ -55,6 +55,7 @@ class Evaluator: def evaluate(self): log.debug('evaluate') + log.info('Starting alarm evaluation') alarms_tuples = self.service.evaluate_alarms() processes = [] for alarm, status in alarms_tuples: @@ -64,14 +65,16 @@ class Evaluator: processes.append(p) for process in processes: process.join(timeout=10) + log.info('Alarm evaluation is complete') def notify_alarm(self, alarm: Alarm, status: AlarmStatus): - log.debug("notify_alarm") + log.debug("_notify_alarm") resp_message = self._build_alarm_response(alarm, status) log.info("Sent alarm notification: %s", resp_message) self.loop.run_until_complete(self.msg_bus.aiowrite('alarm_response', 'notify_alarm', resp_message)) def _build_alarm_response(self, alarm: Alarm, status: AlarmStatus): + log.debug("_build_alarm_response") response = ResponseBuilder() tags = {} for name, value in alarm.tags.items():