Function get_pid

tests/utils/io.py:41–45

()

    wait_for_job_state(hq_env, job_id, "RUNNING")

    def get_pid():
        pid = read_file(default_task_output(job_id=job_id)).strip()
        if not pid:
            return None
        return int(pid)

    return wait_until(get_pid)