diff --git a/pyiceberg/table/__init__.py b/pyiceberg/table/__init__.py index 3d6bcfc493..620a331e5e 100644 --- a/pyiceberg/table/__init__.py +++ b/pyiceberg/table/__init__.py @@ -2022,9 +2022,9 @@ def projection(self) -> Schema: return current_schema.select(*self.selected_fields, case_sensitive=self.case_sensitive) @abstractmethod - def _do_plan_files(self, from_snapshot_id_exclusive: int, to_snapshot_id: int) -> Iterable[FileScanTask]: ... + def _do_plan_files(self, from_snapshot_id_exclusive: int, to_snapshot_id: int) -> Iterable[ScanTask]: ... - def plan_files(self) -> Iterable[FileScanTask]: + def plan_files(self) -> Iterable[ScanTask]: if ( self.from_snapshot_id_exclusive is None and self.to_snapshot_id is None