You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
_DeleteFiles.delete_data_file() silently drops explicit file references because _compute_deletes resets self._deleted_data_files = set() before scanning manifests by predicate.
The delete_data_file() method is inherited from _SnapshotProducer and adds to self._deleted_data_files. However, when _DeleteFiles._compute_deletes runs (triggered by _deleted_entries()), it resets this field to an empty set and repopulates it only from files matched by the predicate evaluator. Any explicitly added files are silently lost.
While the high-level table.delete() API only uses predicates (so this isn't hit in normal usage), the low-level update_snapshot().delete() API exposes delete_data_file() as a public method. Calling it produces no error and no effect.
Reproduction
importpyarrowaspafrompyiceberg.catalogimportload_catalogfrompyiceberg.schemaimportSchemafrompyiceberg.typesimportLongType, NestedFieldcatalog=load_catalog("default")
catalog.create_namespace("default")
table=catalog.create_table(
"default.delete_explicit",
Schema(NestedField(1, "x", LongType(), required=False)),
)
table.append(pa.table({"x": [1, 2, 3]}))
data_file=next(iter(table.scan().plan_files())).file# This should delete the file but silently does nothingwithtable.transaction() astx:
delete_snapshot=tx.update_snapshot().delete()
delete_snapshot.delete_data_file(data_file)
# Bug: table still has [1, 2, 3]print(table.scan().to_arrow()["x"].to_pylist())
Expected: table is empty after commit.
Actual: table still has [1, 2, 3].
Root cause
In pyiceberg/table/update/snapshot.py, _DeleteFiles._compute_deletes (line ~598):
self._deleted_data_files=set() # <-- overwrites any explicit files added via delete_data_file()
Then it repopulates from predicate matches only. Since no predicate was set (AlwaysFalse by default), nothing matches, nothing is deleted.
Suggested fix
Before resetting, preserve explicit files and include them in the deletion scan:
# Preserve files explicitly requested for deletionexplicit_deletes=set(self._deleted_data_files)
self._deleted_data_files=set()
# ... existing predicate-based scan ...# After the scan, also mark explicitly requested files as deleted:forentryinmanifest_entries:
ifentry.data_fileinexplicit_deletes:
# mark as deleted
Alternatively, prevent calling delete_data_file() on _DeleteFiles entirely by raising NotImplementedError.
Related
Follow-up observation from #3818 review. The _OverwriteFiles path handles delete_data_file() correctly because it does not reset the field.
Activity
Core: Preserve explicit delete_data_file() in _DeleteFiles._compute_d…
Core: Preserve explicit delete_data_file() in _DeleteFiles._compute_d…
Core: Preserve explicit delete_data_file() in _DeleteFiles._compute_d…