diff --git a/spindle/xrpc/pipeline_cancel_pipeline.go b/spindle/xrpc/pipeline_cancel_pipeline.go index 0238c946..ac1cdaab 100644 --- a/spindle/xrpc/pipeline_cancel_pipeline.go +++ b/spindle/xrpc/pipeline_cancel_pipeline.go @@ -64,6 +64,7 @@ func (x *Xrpc) CancelPipeline(w http.ResponseWriter, r *http.Request) { Knot: repo.Knot, Rkey: pipelineTid.String(), } + l = l.With("input.pipeline", pipelineTid, "input.workflows", input.Workflows) workflows := input.Workflows if len(workflows) == 0 { @@ -73,6 +74,11 @@ func (x *Xrpc) CancelPipeline(w http.ResponseWriter, r *http.Request) { } } + canceled := false + defer func() { + l.Debug("canceled pipeline", "canceled", canceled) + }() + for _, wName := range workflows { wid := models.WorkflowId{ PipelineId: pipelineId, @@ -95,5 +101,7 @@ func (x *Xrpc) CancelPipeline(w http.ResponseWriter, r *http.Request) { } } + canceled = true + w.WriteHeader(http.StatusOK) }