From a22ee2e1e6253c8907cc6677d909dcf36b9c8ebd Mon Sep 17 00:00:00 2001
From: Shreyas Goenka <shreyas.goenka@databricks.com>
Date: Thu, 9 Mar 2023 01:48:34 +0100
Subject: [PATCH] log log failure

---
 bundle/run/pipeline.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 {