diff --git a/bundle/run/pipeline.go b/bundle/run/pipeline.go
index be49a1fcf..a10aa4671 100644
--- a/bundle/run/pipeline.go
+++ b/bundle/run/pipeline.go
@@ -205,7 +205,10 @@ func (r *pipelineRunner) Run(ctx context.Context, opts *Options) error {
 		}
 		if state == pipelines.UpdateInfoStateFailed {
 			log.Printf("%s Update has failed!", prefix)
-			r.logErrorEvent(ctx, pipelineID, updateID)
+			err := r.logErrorEvent(ctx, pipelineID, updateID)
+			if err != nil {
+				return err
+			}
 			return fmt.Errorf("update failed")
 		}
 		if state == pipelines.UpdateInfoStateCompleted {