Function test_intersect

python/pathway/tests/test_persistence.py:414–428

(tmp_path, mode)

)
@only_with_license_key("mode", [api.PersistenceMode.OPERATOR_PERSISTING])
def test_intersect(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.intersect(t_2)

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

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


@pytest.mark.parametrize(