From 555e6a0ed786a3e8c8e1caefce5a9f6d6dec22fd Mon Sep 17 00:00:00 2001
From: Andrew Nester <andrew.nester@databricks.com>
Date: Fri, 8 Sep 2023 11:35:04 +0200
Subject: [PATCH] Do not include empty output in job run output

---
 bundle/run/output/job.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/bundle/run/output/job.go b/bundle/run/output/job.go
index 4bea4c7ad8..6199ac2f72 100644
--- a/bundle/run/output/job.go
+++ b/bundle/run/output/job.go
@@ -60,7 +60,7 @@ func GetJobOutput(ctx context.Context, w *databricks.WorkspaceClient, runId int6
 		return nil, err
 	}
 	result := &JobOutput{
-		TaskOutputs: make([]TaskOutput, len(jobRun.Tasks)),
+		TaskOutputs: make([]TaskOutput, 0),
 	}
 	for _, task := range jobRun.Tasks {
 		jobRunOutput, err := w.Jobs.GetRunOutput(ctx, jobs.GetRunOutputRequest{
@@ -69,7 +69,11 @@ func GetJobOutput(ctx context.Context, w *databricks.WorkspaceClient, runId int6
 		if err != nil {
 			return nil, err
 		}
-		task := TaskOutput{TaskKey: task.TaskKey, Output: toRunOutput(jobRunOutput), EndTime: task.EndTime}
+		out := toRunOutput(jobRunOutput)
+		if out == nil {
+			continue
+		}
+		task := TaskOutput{TaskKey: task.TaskKey, Output: out, EndTime: task.EndTime}
 		result.TaskOutputs = append(result.TaskOutputs, task)
 	}
 	return result, nil