Function test_buffer

python/pathway/tests/test_column_properties.py:233–241

(append_only)

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

    table = table_from_datasource(TestDataSource(schema=Schema))
    result = table._buffer(pw.this.a + 10, pw.this.a)

    assert result._id_column.properties.append_only == append_only
    assert result.a._column.properties.append_only == append_only


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