(jobKey spec.JobKey)
| 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())) |
| 325 | if err != nil { |
| 326 | return err |
| 327 | } |
| 328 | |
| 329 | err = DeleteInProgressFile(jobKey) |
| 330 | if err != nil { |
| 331 | return err |
| 332 | } |
| 333 | |
| 334 | return nil |
| 335 | } |
| 336 | |
| 337 | func SetRunningStatus(jobKey spec.JobKey) error { |
| 338 | err := config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, path.Join(jobKey.Prefix(config.ClusterConfig.ClusterUID), status.JobRunning.String())) |
nothing calls this directly
no test coverage detected