Add an overide list

lib/krane/cluster_resource_discovery.rb

@@ -20,11 +20,23 @@ def prunable_resources
       api_versions = fetch_api_versions
       fetch_resources.map do |resource|
         next unless resource['verbs'].include?("delete")
-        version = api_versions.fetch(resource['apigroup'], ['v1']).last
+        version = latest_version(api_versions.fetch(resource['apigroup'], ['v1']), resource['kind'])
         [resource['apigroup'], version, resource['kind']].compact.join("/")
       end.compact
     end
 
+    def latest_version(versions, kind)
+      version_override = { "CronJob" => "v1beta1", "VolumeAttachment" => "v1beta1",
+                           "CSIDriver" => "v1beta1", "Ingress" => "v1beta1" }
+
+      pattern = /v(?<major>\d+)(beta)?(?<minor>\d+)?/
+      latest = versions.sort_by do |version|
+        match = version.match(pattern)
+        [match[:major].to_i, (match[:minor] || 999).to_i]
+      end.last
+      version_override.fetch(kind, latest)
+    end
+
     def fetch_resources(only_globals: false, only_namespaced: false)
       command = %w(api-resources)
       command << "--namespaced=false" if only_globals

lib/krane/deploy_task.rb

@@ -10,9 +10,8 @@ def initialize(**args)
     end
 
     def prune_whitelist
-      black_list = %w(batch/v1beta1/Job)
       cluster_resource_discoverer.prunable_resources.select do |gvk|
-        @task_config.namespaced_kinds.any? { |g| gvk.include?(g) } && black_list.none? { |b| gvk.include?(b) }
+        @task_config.namespaced_kinds.any? { |g| gvk.include?(g) }
       end
     end
   end