show warning when max running jobs limit has been reached

cenkalti · Oct 2, 2020 · 3a4a8b5 · 3a4a8b5
1 parent 3a83a62
commit 3a4a8b5
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/scheduler/scheduler.go b/internal/scheduler/scheduler.go
@@ -107,6 +107,13 @@ func (s *Scheduler) runOnce(ctx context.Context) bool {
 		case s.maxRunning <- struct{}{}:
 		case <-ctx.Done():
 			return false
+		default:
+			log.Printf("max running jobs (%d) has been reached", cap(s.maxRunning))
+			select {
+			case s.maxRunning <- struct{}{}:
+			case <-ctx.Done():
+				return false
+			}
 		}
 	}
 	s.wg.Add(1)