Function wait_result

python/pathway/tests/test_persistence.py:745–759

(inputs: list[str], expected: set[str])

    )

    def wait_result(inputs: list[str], expected: set[str]) -> None:
        nonlocal count
        count += 1
        G.clear()
        path = input_path / str(count)
        write_lines(path, inputs)
        t_1 = pw.io.csv.read(input_path, schema=InputSchema, mode="streaming")
        res = t_1._buffer(pw.this.t + 10, pw.this.t)
        pw.io.csv.write(res, output_path)
        wait_result_with_checker(
            get_checker(output_path, expected),
            timeout_sec=10,
            target=run,
            kwargs={"persistence_config": persistence_config},
        )

    wait_result(["t", "1", "3", "11"], {"1,1"})
    wait_result(["t", "15", "16"], {"3,1"})