Function StopJob

cli/cluster/delete.go:77–102

(operatorConfig OperatorConfig, kind userconfig.Kind, apiName string, jobID string)

}

func StopJob(operatorConfig OperatorConfig, kind userconfig.Kind, apiName string, jobID string) (schema.DeleteResponse, error) {
	params := map[string]string{
		"apiName": apiName,
		"jobID":   jobID,
	}

	var endpointComponent string
	if kind == userconfig.BatchAPIKind {
		endpointComponent = "batch"
	} else {
		endpointComponent = "tasks"
	}

	httpRes, err := HTTPDelete(operatorConfig, path.Join("/"+endpointComponent, apiName), params)
	if err != nil {
		return schema.DeleteResponse{}, err
	}

	var deleteRes schema.DeleteResponse
	err = json.Unmarshal(httpRes, &deleteRes)
	if err != nil {
		return schema.DeleteResponse{}, errors.Wrap(err, string(httpRes))
	}

	return deleteRes, nil
}