(jobKey spec.JobKey)
| 433 | } |
| 434 | |
| 435 | func SetUnexpectedErrorStatus(jobKey spec.JobKey) error { |
| 436 | err := config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, path.Join(jobKey.Prefix(config.ClusterConfig.ClusterUID), status.JobUnexpectedError.String())) |
| 437 | if err != nil { |
| 438 | return err |
| 439 | } |
| 440 | |
| 441 | err = DeleteInProgressFile(jobKey) |
| 442 | if err != nil { |
| 443 | return err |
| 444 | } |
| 445 | |
| 446 | return nil |
| 447 | } |
| 448 | |
| 449 | func SetTimedOutStatus(jobKey spec.JobKey) error { |
| 450 | err := config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, path.Join(jobKey.Prefix(config.ClusterConfig.ClusterUID), status.JobTimedOut.String())) |
no test coverage detected