From 24f8a279a8e315620937b2b3da1aa577b5b88783 Mon Sep 17 00:00:00 2001 From: Em Sharnoff Date: Sat, 14 Dec 2024 15:15:35 -0800 Subject: [PATCH] tmp: notifyEnqueued() when queued item is updated --- pkg/plugin/reconcile/queue.go | 3 +++ 1 file changed, 3 insertions(+) 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 }