Function DeleteInProgressFile

pkg/operator/resources/job/cache.go:36–42

(jobKey spec.JobKey)

}

func DeleteInProgressFile(jobKey spec.JobKey) error {
	err := config.AWS.DeleteS3File(config.ClusterConfig.Bucket, inProgressKey(jobKey))
	if err != nil {
		return err
	}
	return nil
}

func DeleteAllInProgressFilesByAPI(kind userconfig.Kind, apiName string) error {
	err := config.AWS.DeleteS3Prefix(config.ClusterConfig.Bucket, allInProgressForAPIKey(kind, apiName), true)