(jobKey spec.JobKey)
| 302 | } |
| 303 | |
| 304 | func SetEnqueuingStatus(jobKey spec.JobKey) error { |
| 305 | err := UpdateLiveness(jobKey) |
| 306 | if err != nil { |
| 307 | return err |
| 308 | } |
| 309 | |
| 310 | err = config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, path.Join(jobKey.Prefix(config.ClusterConfig.ClusterUID), status.JobEnqueuing.String())) |
| 311 | if err != nil { |
| 312 | return err |
| 313 | } |
| 314 | |
| 315 | err = uploadInProgressFile(jobKey) |
| 316 | if err != nil { |
| 317 | return err |
| 318 | } |
| 319 | |
| 320 | return nil |
| 321 | } |
| 322 | |
| 323 | func SetFailedStatus(jobKey spec.JobKey) error { |
| 324 | err := config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, path.Join(jobKey.Prefix(config.ClusterConfig.ClusterUID), status.JobEnqueueFailed.String())) |
no test coverage detected