diff --git a/operator/runner/runner.go b/operator/runner/runner.go
index 00669cd0..25c97a7f 100644
--- a/operator/runner/runner.go
+++ b/operator/runner/runner.go
@@ -222,6 +222,7 @@ func (r *Runner) Run(ctx context.Context, id int64) error {
 		}
 		if v.Name == m.Stage.Name {
 			pipeline = v
+			break
 		}
 	}
 	if pipeline == nil {