-# -*- coding: utf-8 -*-
-
# Copyright 2018 Whitestack, LLC
# *************************************************************
class Evaluator:
- def __init__(self, config: Config, loop=None):
+ def __init__(self, config: Config):
self.conf = config
- if not loop:
- loop = asyncio.get_event_loop()
- self.loop = loop
self.service = EvaluatorService(config)
self.msg_bus = MessageBusClient(config)
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(
+ asyncio.run(
self.msg_bus.aiowrite("alarm_response", "notify_alarm", resp_message)
)
evaluator_service = EvaluatorService(self.conf)
evaluator_service.update_alarm_status(status.value, alarm.uuid)
+ evaluator_service.update_alarm_extra_labels(alarm.extra_labels, alarm.uuid)
return
def _build_alarm_response(self, alarm: Alarm, status: AlarmStatus):
status=status.value,
date=now,
tags=tags,
+ extra_tabels=alarm.extra_labels,
)