Skip to content

Commit d65a8a4

Browse files
committed
Make ruff happy
1 parent edfadd9 commit d65a8a4

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

pyiceberg/table/__init__.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -469,7 +469,10 @@ def overwrite(
469469
update_snapshot.append_data_file(data_file)
470470

471471
def delete(self, delete_filter: BooleanExpression, snapshot_properties: Dict[str, str] = EMPTY_DICT) -> None:
472-
if self.table_metadata.properties.get(TableProperties.DELETE_MODE, TableProperties.DELETE_MODE_COPY_ON_WRITE) == TableProperties.DELETE_MODE_MERGE_ON_READ:
472+
if (
473+
self.table_metadata.properties.get(TableProperties.DELETE_MODE, TableProperties.DELETE_MODE_COPY_ON_WRITE)
474+
== TableProperties.DELETE_MODE_MERGE_ON_READ
475+
):
473476
raise NotImplementedError("Merge on read is not yet supported")
474477

475478
with self.update_snapshot(snapshot_properties=snapshot_properties).delete() as delete_snapshot:

tests/integration/test_rest_schema.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2525,6 +2525,7 @@ def test_two_add_schemas_in_a_single_transaction(catalog: Catalog) -> None:
25252525
NestedField(field_id=3, name="baz", field_type=StringType()),
25262526
)
25272527

2528+
25282529
@pytest.mark.integration
25292530
def test_create_table_integrity_after_fresh_assignment(catalog: Catalog) -> None:
25302531
schema = Schema(

0 commit comments

Comments
 (0)