Function wait_for_worker_state

tests/utils/wait.py:79–80

(env, ids: Union[int, List[int]], target_states: Union[str, List[str]], **kwargs)

def wait_for_worker_state(env, ids: Union[int, List[int]], target_states: Union[str, List[str]], **kwargs):
    wait_for_state(env, ids, target_states, ["worker", "list", "--all"], 1, **kwargs)


def wait_for_task_state(env, job_id: int, task_ids: Union[int, List[int]], states: Union[str, List[str]], **kwargs):