Function getBatchJob

cli/cmd/lib_batch_apis.go:145–278

(env cliconfig.Environment, apiName string, jobID string)

}

func getBatchJob(env cliconfig.Environment, apiName string, jobID string) (string, error) {
	resp, err := cluster.GetBatchJob(MustGetOperatorConfig(env.Name), apiName, jobID)
	if err != nil {
		return "", err
	}

	var bytes []byte
	if _flagOutput == flags.JSONOutputType {
		bytes, err = libjson.Marshal(resp)
	} else if _flagOutput == flags.YAMLOutputType {
		bytes, err = yaml.Marshal(resp)
	}
	if err != nil {
		return "", err
	}
	if _flagOutput == flags.JSONOutputType || _flagOutput == flags.YAMLOutputType {
		return string(bytes), nil
	}

	job := resp.JobStatus

	out := ""

	jobIntroTable := table.KeyValuePairs{}
	jobIntroTable.Add("job id", job.ID)
	jobIntroTable.Add("status", job.Status.Message())
	out += jobIntroTable.String(&table.KeyValuePairOpts{BoldKeys: pointer.Bool(true)})

	jobTimingTable := table.KeyValuePairs{}
	jobTimingTable.Add("start time", job.StartTime.Format(_timeFormat))

	jobEndTime := time.Now()
	if job.EndTime != nil {
		jobTimingTable.Add("end time", job.EndTime.Format(_timeFormat))
		jobEndTime = *job.EndTime
	} else {
		jobTimingTable.Add("end time", "-")
	}
	duration := jobEndTime.Sub(job.StartTime).Truncate(time.Second).String()
	jobTimingTable.Add("duration", duration)

	out += "\n" + jobTimingTable.String(&table.KeyValuePairOpts{BoldKeys: pointer.Bool(true)})

	succeeded := "-"
	failed := "-"
	avgTimePerBatch := "-"

	if resp.Metrics != nil {
		if resp.Metrics.AverageTimePerBatch != nil {
			batchMetricsDuration := time.Duration(*resp.Metrics.AverageTimePerBatch*1000000000) * time.Nanosecond
			avgTimePerBatch = batchMetricsDuration.Truncate(time.Millisecond).String()
		}

		succeeded = s.Int(resp.Metrics.Succeeded)
		failed = s.Int(resp.Metrics.Failed)
	}

	t := table.Table{