diff --git a/services/escalator/escalation.py b/services/escalator/escalation.py index 62fbb1ae8684f74d1a637c1c6fb3fc899b5646f0..072d4071fa867b7fbac697d3eab8c21b555b443e 100644 --- a/services/escalator/escalation.py +++ b/services/escalator/escalation.py @@ -126,6 +126,11 @@ def escalate(alarm_id, escalation_id, escalation_delay, login="correlator", *arg "Escalation limit exceeded (%s/%s). Skipping" % (ae, config.escalator.tt_escalation_limit) ) + Job.retry_after( + get_next_retry(), + "Escalation limit exceeded (%s/%s). Skipping" + % (ae, config.escalator.tt_escalation_limit), + ) return # Check whether consequences has escalations cons_escalated = sorted(alarm.iter_escalated(), key=operator.attrgetter("timestamp"))