Function DownloadTaskJobSpec

pkg/operator/operator/storage.go:69–75

(jobKey spec.JobKey)

}

func DownloadTaskJobSpec(jobKey spec.JobKey) (*spec.TaskJob, error) {
	jobSpec := spec.TaskJob{}
	if err := config.AWS.ReadJSONFromS3(&jobSpec, config.ClusterConfig.Bucket, jobKey.SpecFilePath(config.ClusterConfig.ClusterUID)); err != nil {
		return nil, errors.Wrap(err, "unable to download job specification", jobKey.UserString())
	}
	return &jobSpec, nil
}