'Wait until all cluster nodes are in a \'running\' state'

def wait_for_ssh(self, nodes=None):

    log.info('Waiting    for    SSH    to    come    up    on    all    nodes...')
    nodes = (nodes or self.get_nodes_or_raise())
    self.pool.map((lambda n: n.wait(interval=self.refresh_interval)), nodes, jobid_fn=(lambda n: n.alias))
