fix: fix missing error return in pipeline trigger

instill-ai · Mar 11, 2024 · a743ab1 · a743ab1
1 parent ce720d5
commit a743ab1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/worker/workflow.go b/pkg/worker/workflow.go
@@ -297,6 +297,7 @@ func (w *worker) TriggerPipelineWorkflow(ctx workflow.Context, param *TriggerPip
 	})
 	if err != nil {
 		w.writeErrorDataPoint(sCtx, err, span, startTime, &dataPoint)
+		return nil, err
 	}
 
 	pipelineOutputs := []*structpb.Struct{}