|
25 | 25 | from pyiceberg.manifest import ManifestContent, ManifestEntry, ManifestEntryStatus, ManifestFile
|
26 | 26 | from pyiceberg.table import Table
|
27 | 27 | from pyiceberg.table.snapshots import Operation, Snapshot, Summary
|
28 |
| -from pyiceberg.table.update.validate import _deleted_data_files, _validate_deleted_data_files, validation_history |
| 28 | +from pyiceberg.table.update.validate import _deleted_data_files, _validate_deleted_data_files, _validation_history |
29 | 29 |
|
30 | 30 |
|
31 | 31 | @pytest.fixture
|
@@ -69,7 +69,7 @@ def mock_read_manifest_side_effect(self: Snapshot, io: FileIO) -> list[ManifestF
|
69 | 69 | return []
|
70 | 70 |
|
71 | 71 | with patch("pyiceberg.table.snapshots.Snapshot.manifests", new=mock_read_manifest_side_effect):
|
72 |
| - manifests, snapshots = validation_history( |
| 72 | + manifests, snapshots = _validation_history( |
73 | 73 | table,
|
74 | 74 | oldest_snapshot,
|
75 | 75 | newest_snapshot,
|
@@ -99,7 +99,7 @@ def test_validation_history_fails_on_snapshot_with_no_summary(
|
99 | 99 | )
|
100 | 100 | with patch("pyiceberg.table.update.validate.ancestors_between", return_value=[snapshot_with_no_summary]):
|
101 | 101 | with pytest.raises(ValidationException):
|
102 |
| - validation_history( |
| 102 | + _validation_history( |
103 | 103 | table,
|
104 | 104 | oldest_snapshot,
|
105 | 105 | newest_snapshot,
|
@@ -129,7 +129,7 @@ def mock_read_manifest_side_effect(self: Snapshot, io: FileIO) -> list[ManifestF
|
129 | 129 | with patch("pyiceberg.table.snapshots.Snapshot.manifests", new=mock_read_manifest_side_effect):
|
130 | 130 | with patch("pyiceberg.table.update.validate.ancestors_between", return_value=missing_oldest_snapshot):
|
131 | 131 | with pytest.raises(ValidationException):
|
132 |
| - validation_history( |
| 132 | + _validation_history( |
133 | 133 | table,
|
134 | 134 | oldest_snapshot,
|
135 | 135 | newest_snapshot,
|
|
0 commit comments