Function DeleteAllInProgressFilesByAPI

pkg/operator/resources/job/cache.go:44–50

(kind userconfig.Kind, apiName string)

}

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

func listAllInProgressJobKeysByAPI(kind userconfig.Kind, apiName *string) ([]spec.JobKey, error) {
	_, ok := _jobKinds[kind]