diff --git a/services/escalator/escalation.py b/services/escalator/escalation.py index 99fe1e248c7a4b05c0b5f15b97fa17896654a707..725e1f147bfc569ce54e01e0d9acbd699742552e 100644 --- a/services/escalator/escalation.py +++ b/services/escalator/escalation.py @@ -125,6 +125,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"))