code: def _cleanup_pods(namespace, labels):
      
      api = kubernetes.client.CoreV1Api()
      pods = api.list_namespaced_pod(namespace, label_selector=format_labels(labels))
      for pod in pods.items:
          try:
              api.delete_namespaced_pod(pod.metadata.name, namespace)
              logger.info('Deleted pod: %s', pod.metadata.name)
          except kubernetes.client.rest.ApiException as e:
              # ignore error if pod is already removed
              if e.status != 404:
                  raise
docs: Remove all pods with these labels in this namespace