add message to kubernetes kill if no pods were found to be killed. (#…

…2062)

metaflow/plugins/kubernetes/kubernetes_client.py

@@ -121,7 +121,10 @@ def kill_pods(self, flow_name, run_id, user, echo):
  job_api = self._client.BatchV1Api()
  pods = self._find_active_pods(flow_name, run_id, user)
 
+ active_pods = False
+
  def _kill_pod(pod):
+ active_pods = True
  echo("Killing Kubernetes pod %s\n" % pod.metadata.name)
  try:
  stream(
@@ -155,7 +158,10 @@ def _kill_pod(pod):
  echo("failed to kill pod %s - %s" % (pod.metadata.name, str(e)))
 
  with ThreadPoolExecutor() as executor:
- executor.map(_kill_pod, list(pods))
+ executor.map(_kill_pod, pods)
+
+ if not active_pods:
+ echo("No active Kubernetes pods found for run *%s*" % run_id)
 
  def jobset(self, **kwargs):
  return KubernetesJobSet(self, **kwargs)