- log.info("Received delete_alarm_response %s", content)
- if content['alarm_delete_response']['correlation_id'] == cor_id:
- if not content['alarm_delete_response']['status']:
- raise ValueError("Error deleting alarm in MON")
- alarm_uuid = content['alarm_delete_response']['alarm_uuid']
- await consumer.stop()
- return alarm_uuid
+ except JSONDecodeError:
+ content = yaml.safe_load(message.value)
+ if content['alarm_delete_response']['correlation_id'] == cor_id:
+ log.debug("Received delete_alarm_response %s", content)
+ if not content['alarm_delete_response']['status']:
+ raise ValueError("Error deleting alarm in MON. Response status is False.")
+ alarm_uuid = content['alarm_delete_response']['alarm_uuid']
+ break