def remove_all_pods()

in drainer/k8s_utils.py [0:0]

• 5 lines of code
• 1 McCabe index (conditional complexity)

def remove_all_pods(api, node_name, poll=5):
    """Removes all Kubernetes pods from the specified node."""
    pods = get_evictable_pods(api, node_name)

    logger.debug('Number of pods to delete: ' + str(len(pods)))

    evict_until_completed(api, pods, poll)
    wait_until_empty(api, node_name, poll)