DATA-4500 Update CLI + Go SDK (#5222)

Author: vijayvuyyuru

app/data_client.go

@@ -436,6 +436,8 @@ type DataPipelineRun struct {
 	DataEndTime time.Time
 	// Status is the run's current status.
 	Status DataPipelineRunStatus
+	// ErrorMessage is the error message of the data pipeline run. It is only set if the run failed.
+	ErrorMessage string
 }
 
 // ListDataPipelineRunsPage is a results page of data pipeline runs, used for pagination.
@@ -1916,6 +1918,7 @@ func dataPipelineRunFromProto(proto *datapipelinesPb.DataPipelineRun) *DataPipel
 		DataStartTime: proto.DataStartTime.AsTime(),
 		DataEndTime:   proto.DataEndTime.AsTime(),
 		Status:        dataPipelineRunStatusFromProto(proto.Status),
+		ErrorMessage:  proto.ErrorMessage,
 	}
 }
 

app/data_client_test.go

@@ -187,6 +187,15 @@ var (
 			DataStartTime: timestamppb.New(time.Date(2023, 1, 1, 11, 0, 0, 0, time.UTC)),
 			DataEndTime:   timestamppb.New(time.Date(2023, 1, 1, 12, 30, 0, 0, time.UTC)),
 		},
+		{
+			Id:            "run2",
+			Status:        datapipelinesPb.DataPipelineRunStatus_DATA_PIPELINE_RUN_STATUS_FAILED,
+			StartTime:     timestamppb.New(time.Date(2023, 1, 1, 12, 0, 0, 0, time.UTC)),
+			EndTime:       timestamppb.New(time.Date(2023, 1, 1, 12, 5, 0, 0, time.UTC)),
+			DataStartTime: timestamppb.New(time.Date(2023, 1, 1, 11, 0, 0, 0, time.UTC)),
+			DataEndTime:   timestamppb.New(time.Date(2023, 1, 1, 12, 30, 0, 0, time.UTC)),
+			ErrorMessage:  "error message",
+		},
 	}
 	dataPipelineRuns = []*DataPipelineRun{
 		{
@@ -197,6 +206,15 @@ var (
 			DataStartTime: time.Date(2023, 1, 1, 11, 0, 0, 0, time.UTC),
 			DataEndTime:   time.Date(2023, 1, 1, 12, 30, 0, 0, time.UTC),
 		},
+		{
+			ID:            "run2",
+			Status:        DataPipelineRunStatusFailed,
+			StartTime:     time.Date(2023, 1, 1, 12, 0, 0, 0, time.UTC),
+			EndTime:       time.Date(2023, 1, 1, 12, 5, 0, 0, time.UTC),
+			DataStartTime: time.Date(2023, 1, 1, 11, 0, 0, 0, time.UTC),
+			DataEndTime:   time.Date(2023, 1, 1, 12, 30, 0, 0, time.UTC),
+			ErrorMessage:  "error message",
+		},
 	}
 )
 

cli/datapipelines.go

@@ -211,6 +211,9 @@ func DatapipelineDescribeAction(c *cli.Context, args datapipelineDescribeArgs) e
 		if r.GetEndTime() != nil {
 			printf(c.App.Writer, "  Ended: %s", r.GetEndTime().AsTime().Format(time.RFC3339))
 		}
+		if r.GetErrorMessage() != "" {
+			printf(c.App.Writer, "  Error: %s", r.GetErrorMessage())
+		}
 	} else {
 		printf(c.App.Writer, "Has not run yet.")
 	}