Merge pull request #1130 from Garrybest/pr_rate
add rate limited when errors occur in scheduler
This commit is contained in:
commit
00f46c6452
|
@ -582,7 +582,7 @@ func (s *Scheduler) handleErr(err error, key interface{}) {
|
|||
return
|
||||
}
|
||||
|
||||
s.queue.Add(key)
|
||||
s.queue.AddRateLimited(key)
|
||||
metrics.CountSchedulerBindings(metrics.ScheduleAttemptFailure)
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue