Function test_stream_restart

tests/test_stream.py:180–217

(hq_env: HqEnv)

def test_stream_restart(hq_env: HqEnv):
    hq_env.start_server()
    os.mkdir("mylog")
    hq_env.start_workers(1)

    hq_env.command(
        [
            "submit",
            "--stream",
            "mylog",
            "--",
            "bash",
            "-c",
            "echo Start; sleep 2; echo End ${HQ_INSTANCE_ID}",
        ]
    )
    time.sleep(1.0)

    hq_env.kill_worker(1)
    hq_env.start_workers(1)

    wait_for_job_state(hq_env, 1, "FINISHED")

    result = hq_env.command(["output-log", "mylog", "cat", "1", "stdout"])
    assert result == "Start\nEnd 1\n"

    table = hq_env.command(["output-log", "mylog", "summary"], as_table=True)
    print(table)
    assert table[1] == ["Files", "2"]
    assert table[2] == ["Jobs", "1"]
    assert table[3] == ["Tasks", "1"]
    assert table[4] == ["Opened streams", "0"]
    assert table[5] == ["Stdout/stderr size", "12 B / 0 B"]
    assert table[6] == ["Superseded streams", "1"]
    assert table[7] == ["Superseded stdout/stderr size", "6 B / 0 B"]

    result = hq_env.command(["output-log", "mylog", "show"])
    assert result == "1.0:0> Start\n1.0:0> End 1\n"


def test_stream_partial(hq_env: HqEnv):