20984: Wake up scheduler whenever AtCapacity condition expires.

Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@curii.com>

diff --git a/lib/dispatchcloud/worker/pool.go b/lib/dispatchcloud/worker/pool.go
index fc9f5445d6504dff89f02ebc9de65b80f56f28b4..13c369d0c65113015cb4297375a0d11d815d9ad9 100644 (file)
--- a/lib/dispatchcloud/worker/pool.go
+++ b/lib/dispatchcloud/worker/pool.go
@@ -393,6 +393,7 @@ func (wp *Pool) Create(it arvados.InstanceType) bool {
                                        wp.atCapacityUntil = map[string]time.Time{}
                                }
                                wp.atCapacityUntil[capKey] = time.Now().Add(capacityErrorTTL)
+                               time.AfterFunc(capacityErrorTTL, wp.notify)
                        }
                        logger.WithError(err).Error("create failed")
                        wp.instanceSet.throttleCreate.CheckRateLimitError(err, wp.logger, "create instance", wp.notify)