114
115
if result.DroppedCount > 0 {
116
>
// Only system log on the first drop, as it's likely that a case that overruns
generator_tasks.go
117
>
// will continue to overrun.
118
>
if scheduler.Info.BufferDropped == 0 {
119
>
logger.Warn("Buffer is overruning, dropping actions",
120
>
tag.Int64("dropped-count", result.DroppedCount))
121
>
}
122
124
>
fmt.Sprintf("buffer overrun, dropped %d actions", result.DroppedCount))
125
>
metricsHandler.Counter(metrics.ScheduleBufferOverruns.Name()).Record(result.DroppedCount)
126
>
scheduler.Info.BufferDropped += result.DroppedCount
127
}
128