From 3b5644bb5b0f927895f8e7a733addccd9d096adf Mon Sep 17 00:00:00 2001 From: Liwei Li Date: Wed, 5 Jun 2024 10:34:20 +0800 Subject: [PATCH] change FileScanTask to ScanTask --- pyiceberg/table/__init__.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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