tmp: notifyEnqueued() when queued item is updated

neondatabase · Dec 14, 2024 · 24f8a27 · 24f8a27
1 parent 8d8a19f
commit 24f8a27
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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
 	}