Function test_explain_deps

tests/test_explain.py:209–243

(hq_env: HqEnv, tmp_path)

def test_explain_deps(hq_env: HqEnv, tmp_path):
    hq_env.start_server()
    hq_env.start_workers(2, cpus=4)

    tmp_path.joinpath("job.toml").write_text(
        """
[[task]]
id = 0
command = ["sleep", "0"]

[[task]]
id = 1
command = ["sleep", "100"]

[[task]]
id = 2
command = ["sleep", "1"]
deps = [0, 1]
"""
    )
    hq_env.command(["job", "submit-file", "job.toml"])
    wait_for_task_state(hq_env, 1, [0, 1, 2], ["finished", "running", "waiting"])
    hq_env.command(["job", "submit-file", "job.toml"])
    r = hq_env.command(["task", "explain", "1", "2"])
    assert r == snapshot(
        """Task 1@2 is not ready to run, because 1/2 dependencies are not finished.
The task can run on 2 workers: 1-2
+-----------+----------+---------+------+----------+---------+
| Worker Id | Runnable | Variant | Type | Provides | Request |
+-----------+----------+---------+------+----------+---------+
| 1         | Yes      | 0       | cpus | 4        | 1       |
| 2         | Yes      | 0       | cpus | 4        | 1       |
+-----------+----------+---------+------+----------+---------+
"""
    )