Function test_intersect

python/pathway/tests/test_column_properties.py:324–336

(append_only_1, append_only_2)

@pytest.mark.parametrize("append_only_1", [True, False])
@pytest.mark.parametrize("append_only_2", [True, False])
def test_intersect(append_only_1, append_only_2):
    class Schema1(pw.Schema, append_only=append_only_1):
        a: int

    class Schema2(pw.Schema, append_only=append_only_2):
        b: int

    table_1 = table_from_datasource(TestDataSource(schema=Schema1))
    table_2 = table_from_datasource(TestDataSource(schema=Schema2))
    result = table_1.intersect(table_2)

    assert result._id_column.properties.append_only == (append_only_1 and append_only_2)
    assert result.a._column.properties.append_only == (append_only_1 and append_only_2)


@pytest.mark.parametrize("append_only_1", [True, False])