steve/databricks-cli
steve
/
databricks-cli
mirror of https://github.com/databricks/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Do not include empty output in job run output (#749) 

## Changes
Do not include empty output in job run output

## Tests
Running a job from CLI, the result:
```
andrew.nester@HFW9Y94129 wheel % databricks bundle run some_other_job --output json
Run URL: https://***/?o=6051921418418893#job/780620378804085/run/386695528477456

2023-09-08 11:33:24 "[default] My Wheel Job" TERMINATED SUCCESS 
{
  "task_outputs": [
    {
      "TaskKey": "TestTask",
      "Output": {
        "result": "Hello from my func\nGot arguments v2:\n['python']\n"
      },
      "EndTime": 1694165597474
    }
  ]
```
This commit is contained in:
Andrew Nester 2023-09-08 11:52:45 +02:00 committed by GitHub
parent 17d9f7dd2a
commit e08f419ef6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bundle/run/output/job.go
View File

@ -60,7 +60,7 @@ func GetJobOutput(ctx context.Context, w *databricks.WorkspaceClient, runId int6
return nil, err return nil, err
} }
result := &JobOutput{ result := &JobOutput{
TaskOutputs: make([]TaskOutput, len(jobRun.Tasks)), TaskOutputs: make([]TaskOutput, 0),
} }
for _, task := range jobRun.Tasks { for _, task := range jobRun.Tasks {
jobRunOutput, err := w.Jobs.GetRunOutput(ctx, jobs.GetRunOutputRequest{ 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 { if err != nil {
return nil, err 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) result.TaskOutputs = append(result.TaskOutputs, task)
} }
return result, nil return result, nil