(jobKey spec.JobKey)
| 77 | } |
| 78 | |
| 79 | func uploadInProgressFile(jobKey spec.JobKey) error { |
| 80 | err := config.AWS.UploadStringToS3("", config.ClusterConfig.Bucket, inProgressKey(jobKey)) |
| 81 | if err != nil { |
| 82 | return err |
| 83 | } |
| 84 | return nil |
| 85 | } |
| 86 | |
| 87 | // e.g. <cluster_uid>/jobs/<job_api_kind>/in_progress |
| 88 | func allInProgressKey(kind userconfig.Kind) string { |
no test coverage detected