|
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