show warning when max running jobs limit has been reached

cenkalti · Oct 2, 2020 · 1318bf6 · 1318bf6
1 parent 3a83a62
commit 1318bf6
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/scheduler/scheduler.go b/internal/scheduler/scheduler.go
@@ -105,6 +105,13 @@ func (s *Scheduler) runOnce(ctx context.Context) bool {
 		// Wait for semaphore
 		select {
 		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
 		}