diff --git a/pkg/plugin/reconcile/queue.go b/pkg/plugin/reconcile/queue.go index 4a6040761..09c75fd3b 100644 --- a/pkg/plugin/reconcile/queue.go +++ b/pkg/plugin/reconcile/queue.go @@ -407,6 +407,9 @@ func (q *Queue) enqueueInactive(k Key, v value) { queuedHandle.Update(func(queuedValue *kv) { queuedValue.v = queuedValue.v.mergeWithNewer(v) }) + // the value of reconcileAt for the item may have changed; we should notify just in case, so + // it's not waiting. + q.notifyEnqueued() return }