X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=osm_policy_module%2Falarming%2Fservice.py;h=a938234ade34e7c4ff4d331f6469743a9560e89b;hb=2c2a7c49cf9325ef2fdf494522fa97ec8b8bec19;hp=13433ba5b763f3862a0743743acf32a03c835345;hpb=46e7efd5d078a9a9b6dabfe161fd266af4e6d349;p=osm%2FPOL.git diff --git a/osm_policy_module/alarming/service.py b/osm_policy_module/alarming/service.py index 13433ba..a938234 100644 --- a/osm_policy_module/alarming/service.py +++ b/osm_policy_module/alarming/service.py @@ -218,6 +218,7 @@ class AlarmingService: database.db.close() async def handle_alarm(self, alarm_uuid: str, status: str, payload: dict): + alert_timeout = int(self.conf.get('alert', 'timeout')) database.db.connect() try: with database.db.atomic(): @@ -234,9 +235,9 @@ class AlarmingService: status, ) try: - requests.post(url=action.url, json=json.dumps(payload)) + requests.post(url=action.url, json=json.dumps(payload), timeout=alert_timeout) except RequestException as e: - log.info("Error connecting to url %s", action.url) + log.info("Error: RequestException while connecting to url %s", action.url) log.debug("RequestException %s", e) except ConnectionError: log.exception("Error connecting to url %s", action.url)