()
| 829 | |
| 830 | |
| 831 | def test_stream_to_table(): |
| 832 | class Schema(pw.Schema): |
| 833 | a: bool = pw.column_definition(append_only=True) |
| 834 | b: int = pw.column_definition(append_only=True) |
| 835 | |
| 836 | table = table_from_datasource(TestDataSource(schema=Schema)) |
| 837 | result = table.stream_to_table(pw.this.a) |
| 838 | |
| 839 | assert not result._id_column.properties.append_only |
| 840 | assert not result.a._column.properties.append_only |
| 841 | assert not result.b._column.properties.append_only |
| 842 | |
| 843 | |
| 844 | def test_from_streams(): |
nothing calls this directly
no test coverage detected