stability: remove all in-flight messages from the PQ on stop

Signed-off-by: Valery Piashchynski <[email protected]>
roadrunner-server · Jul 3, 2024 · 80bc415 · 80bc415
1 parent 5850549
commit 80bc415
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/beanstalkjobs/driver.go b/beanstalkjobs/driver.go
@@ -286,6 +286,9 @@ func (d *Driver) Stop(ctx context.Context) error {
 	// release associated resources
 	d.pool.Stop()
 
+	// remove all pending JOBS associated with the pipeline
+	_ = d.pq.Remove(pipe.Name())
+
 	d.log.Debug("pipeline was stopped", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Int64("elapsed", time.Since(start).Milliseconds()))
 	return nil
 }