(jobKey spec.JobKey)
| 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())) |
| 339 | if err != nil { |
| 340 | return err |
| 341 | } |
| 342 | |
| 343 | err = uploadInProgressFile(jobKey) // in progress file should already be there but just in case |
| 344 | if err != nil { |
| 345 | return err |
| 346 | } |
| 347 | |
| 348 | return nil |
| 349 | } |
| 350 | |
| 351 | func SetStoppedStatus(jobKey spec.JobKey) error { |
| 352 | err := config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, path.Join(jobKey.Prefix(config.ClusterConfig.ClusterUID), status.JobStopped.String())) |
no test coverage detected