(append_only_1, append_only_2, append_only_3)
| 340 | @pytest.mark.parametrize("append_only_2", [True, False]) |
| 341 | @pytest.mark.parametrize("append_only_3", [True, False]) |
| 342 | def test_intersect_2(append_only_1, append_only_2, append_only_3): |
| 343 | class Schema1(pw.Schema): |
| 344 | a: int = pw.column_definition(append_only=append_only_1) |
| 345 | b: int = pw.column_definition(append_only=append_only_2) |
| 346 | |
| 347 | class Schema2(pw.Schema, append_only=append_only_3): |
| 348 | c: int |
| 349 | |
| 350 | table_1 = table_from_datasource(TestDataSource(schema=Schema1)) |
| 351 | table_2 = table_from_datasource(TestDataSource(schema=Schema2)) |
| 352 | result = table_1.intersect(table_2) |
| 353 | |
| 354 | assert result._id_column.properties.append_only == ( |
| 355 | (append_only_1 or append_only_2) and append_only_3 |
| 356 | ) |
| 357 | assert result.a._column.properties.append_only == (append_only_1 and append_only_3) |
| 358 | assert result.b._column.properties.append_only == (append_only_2 and append_only_3) |
| 359 | |
| 360 | |
| 361 | @pytest.mark.parametrize("append_only_1", [True, False]) |
nothing calls this directly
no test coverage detected