Update multi-resource actions in k8s managers

Author: polyaxon-ci

cli/polyaxon/_k8s/manager/async_manager.py

@@ -75,25 +75,21 @@ async def delete_pod(self, name, reraise: bool = False, namespace: str = None):
 
     async def delete_pods(
         self,
-        label_selector: str,
         reraise: bool = False,
         namespace: str = None,
+        **kwargs,
     ):
         try:
             await self.k8s_api.delete_collection_namespaced_pod(  # type: ignore[attr-defined]
                 namespace=namespace or self.namespace,
-                label_selector=label_selector,
+                **kwargs,
             )
-            logger.debug("Pods with label selector `{}` deleted".format(label_selector))
+            logger.debug("Pods deleted. kwargs: `{}` ".format(kwargs))
         except ApiException as e:
             if reraise:
                 raise e
             else:
-                logger.debug(
-                    "Pods with label selector `{}` were not found".format(
-                        label_selector
-                    )
-                )
+                logger.debug("Pods were not found. kwargs: `{}` ".format(kwargs))
 
     async def is_pod_running(
         self, pod_id: str, container_id: str, namespace: str = None

cli/polyaxon/_k8s/manager/manager.py

@@ -744,39 +744,40 @@ def delete_ingress(self, name, reraise: bool = False, namespace: str = None):
 
     def delete_pods(
         self,
-        include_uninitialized=True,
         reraise: bool = False,
         namespace: str = None,
         **kwargs,
     ):
-        objs = self.list_pods(
-            include_uninitialized=include_uninitialized,
-            reraise=reraise,
-            namespace=namespace,
-            **kwargs,
-        )
-        for obj in objs:
-            self.delete_pod(
-                name=obj.metadata.name, reraise=reraise, namespace=namespace
+        try:
+            self.k8s_api.delete_collection_namespaced_pod(
+                namespace=namespace or self.namespace,
+                **kwargs,
             )
+            logger.debug("Pods deleted! kwargs: `{}` ".format(kwargs))
+        except ApiException as e:
+            if reraise:
+                raise e
+            else:
+                logger.debug("Pods were not found. kwargs: `{}` ".format(kwargs))
 
     def delete_jobs(
         self,
-        include_uninitialized=True,
         reraise: bool = False,
         namespace: str = None,
         **kwargs,
     ):
-        objs = self.list_jobs(
-            include_uninitialized=include_uninitialized,
-            reraise=reraise,
-            namespace=namespace,
-            **kwargs,
-        )
-        for obj in objs:
-            self.delete_job(
-                name=obj.metadata.name, reraise=reraise, namespace=namespace
+        try:
+            self.k8s_batch_api.delete_collection_namespaced_job(
+                namespace=namespace or self.namespace,
+                propagation_policy="Foreground",
+                **kwargs,
             )
+            logger.debug("Jobs deleted. kwargs: `{}` ".format(kwargs))
+        except ApiException as e:
+            if reraise:
+                raise e
+            else:
+                logger.debug("Jobs were not found. kwargs: `{}` ".format(kwargs))
 
     def delete_services(self, reraise: bool = False, namespace: str = None, **kwargs):
         objs = self.list_services(reraise=reraise, **kwargs)
@@ -788,18 +789,32 @@ def delete_services(self, reraise: bool = False, namespace: str = None, **kwargs
     def delete_deployments(
         self, reraise: bool = False, namespace: str = None, **kwargs
     ):
-        objs = self.list_deployments(reraise=reraise, **kwargs)
-        for obj in objs:
-            self.delete_deployment(
-                name=obj.metadata.name, reraise=reraise, namespace=namespace
+        try:
+            self.k8s_apps_api.delete_collection_namespaced_deployment(
+                namespace=namespace or self.namespace,
+                propagation_policy="Foreground",
+                **kwargs,
             )
+            logger.debug("Deployments deleted. kwargs: `{}` ".format(kwargs))
+        except ApiException as e:
+            if reraise:
+                raise e
+            else:
+                logger.debug("Deployments were not found. kwargs: `{}` ".format(kwargs))
 
     def delete_ingresses(self, reraise: bool = False, namespace: str = None, **kwargs):
-        objs = self.list_services(reraise=reraise, **kwargs)
-        for obj in objs:
-            self.delete_ingress(
-                name=obj.metadata.name, reraise=reraise, namespace=namespace
+        try:
+            self.networking_v1_beta1_api.delete_collection_namespaced_ingress(
+                namespace=namespace or self.namespace,
+                propagation_policy="Foreground",
+                **kwargs,
             )
+            logger.debug("Ingresses deleted. kwargs: `{}` ".format(kwargs))
+        except ApiException as e:
+            if reraise:
+                raise e
+            else:
+                logger.debug("Ingresses were not found. kwargs: `{}` ".format(kwargs))
 
     def is_pod_running(self, pod_id: str, container_id: str, namespace: str = None):
         event = self.k8s_api.read_namespaced_pod_status(