diff --git a/engine/graph/actions.go b/engine/graph/actions.go index 818612ad..d10e1615 100644 --- a/engine/graph/actions.go +++ b/engine/graph/actions.go @@ -531,6 +531,9 @@ func (obj *Engine) Worker(vertex pgraph.Vertex) error { if err == nil { // || err == engine.ErrClosed return // exited cleanly, we're done } + if err == context.Canceled { + return // we shutdown nicely on request + } // we've got an error... delay = res.MetaParams().Delay