@@ -1162,7 +1162,7 @@ def stop(self, terminate=True, force_stop=False):
11621162 raise Exception ('Cluster operation failed : %s' % (json .dumps (resp .get ('messages' , {}).get ('messages' , {}))))
11631163 return resp
11641164
1165- def kubectl_command (self , args ):
1165+ def run_kubectl (self , args ):
11661166 """
11671167 Runs an arbitrary kubectl command on the cluster.
11681168
@@ -1175,7 +1175,7 @@ def kubectl_command(self, args):
11751175 :rtype: dict
11761176 """
11771177 return self .client ._perform_json (
1178- "POST" , "/admin/clusters/%s/k8s/kubectl" % self .cluster_id ,
1178+ "POST" , "/admin/clusters/%s/k8s/actions/run- kubectl" % self .cluster_id ,
11791179 body = {'args' : args })
11801180
11811181 def delete_finished_jobs (self , delete_failed = False , namespace = None , label_filter = None , dry_run = False ):
@@ -1193,7 +1193,7 @@ def delete_finished_jobs(self, delete_failed=False, namespace=None, label_filter
11931193 :rtype: dict
11941194 """
11951195 return self .client ._perform_json (
1196- "POST" , "/admin/clusters/%s/k8s/jobs/delete-finished" % self .cluster_id ,
1196+ "POST" , "/admin/clusters/%s/k8s/jobs/actions/ delete-finished" % self .cluster_id ,
11971197 params = {'deleteFailed' : delete_failed , 'namespace' : namespace , 'labelFilter' : label_filter , 'dryRun' : dry_run })
11981198
11991199 def delete_finished_pods (self , namespace = None , label_filter = None , dry_run = False ):
@@ -1210,7 +1210,7 @@ def delete_finished_pods(self, namespace=None, label_filter=None, dry_run=False)
12101210 :rtype: dict
12111211 """
12121212 return self .client ._perform_json (
1213- "POST" , "/admin/clusters/%s/k8s/pods/delete-finished" % self .cluster_id ,
1213+ "POST" , "/admin/clusters/%s/k8s/pods/actions/ delete-finished" % self .cluster_id ,
12141214 params = {'namespace' : namespace , 'labelFilter' : label_filter , 'dryRun' : dry_run })
12151215
12161216 def delete_all_pods (self , namespace = None , label_filter = None , dry_run = False ):
@@ -1227,7 +1227,7 @@ def delete_all_pods(self, namespace=None, label_filter=None, dry_run=False):
12271227 :rtype: dict
12281228 """
12291229 return self .client ._perform_json (
1230- "POST" , "/admin/clusters/%s/k8s/pods/delete-all" % self .cluster_id ,
1230+ "POST" , "/admin/clusters/%s/k8s/pods/actions/ delete-all" % self .cluster_id ,
12311231 params = {'namespace' : namespace , 'labelFilter' : label_filter , 'dryRun' : dry_run })
12321232
12331233
0 commit comments