def _wait_for_worker_nodes_to_start_sshd()

in miscellaneous/distributed_tensorflow_mask_rcnn/container-optimized-script-mode/resources/train.py [0:0]

• 9 lines of code
• 4 McCabe index (conditional complexity)

def _wait_for_worker_nodes_to_start_sshd(hosts, interval=1, timeout_in_seconds=180):
    with timeout(seconds=timeout_in_seconds):
        while hosts:
            print("hosts that aren't SSHable yet: %s", str(hosts))
            for host in hosts:
                ssh_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                if _can_connect(host, 22, ssh_socket):
                    hosts.remove(host)
            time.sleep(interval)