BACKPORT: plugin: Fix event queue usage (#430)

Co-authored-by: Sam Kleinman <[email protected]>
neondatabase · Jul 20, 2023 · 0d33520 · 0d33520
1 parent 3ff4973
commit 0d33520
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/plugin/plugin.go b/pkg/plugin/plugin.go
@@ -211,14 +211,13 @@ func makeAutoscaleEnforcerPlugin(
 
 	go func() {
 		for {
-			callback, err := queue.Wait(ctx)
+			callback, err := queue.Wait(ctx) // NB: Wait pulls from the front of the queue
 			if err != nil {
 				logger.Info("Stopped waiting on pod/VM queue", zap.Error(err))
 				break
 			}
 
 			callback()
-			queue.Remove()
 		}
 	}()