def wait_for_workers(self, workers=1, timeout=None):
        return self._finder.wait_for_workers(workers=workers,
                                             timeout=timeout)
Waits for geq workers to notify they are ready to do work.
dataset/ETHPy150Open openstack/taskflow/taskflow/engines/worker_based/executor.py/WorkerTaskExecutor.wait_for_workers