Function test_difference

python/pathway/tests/test_persistence.py:435–449

(tmp_path, mode)

)
@only_with_license_key("mode", [api.PersistenceMode.OPERATOR_PERSISTING])
def test_difference(tmp_path, mode):
    class InputSchema(pw.Schema):
        a: int = pw.column_definition(primary_key=True)

    def logic(t_1: pw.Table, t_2: pw.Table) -> pw.Table:
        return t_1.difference(t_2)

    run, _, input_path_2 = get_two_tables_runner(tmp_path, mode, logic, InputSchema)

    run(["a", "1", "2", "3"], ["a", "1"], {"2,1", "3,1"})
    run(["a"], ["a", "3"], {"3,-1"})
    run(["a", "4", "5"], ["a", "5", "6"], {"4,1"})
    run(["a", "6"], ["a", "4"], {"4,-1"})
    os.remove(input_path_2 / "3")
    run(["a"], ["a"], {"5,1", "6,1"})


@pytest.mark.parametrize(