X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Falarming%2Fservice.py;h=a938234ade34e7c4ff4d331f6469743a9560e89b;hb=3b30c530a5f4a623e042941cf031a3d16dcf1bb1;hp=13433ba5b763f3862a0743743acf32a03c835345;hpb=c2fbf6c5d1747b4ee1e9dd4a3771a617ead9da1d;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)