Skip to content

Commit

Permalink
change FileScanTask to ScanTask
Browse files Browse the repository at this point in the history
  • Loading branch information
hililiwei committed Jul 2, 2024
1 parent 38d8b1e commit 3b5644b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pyiceberg/table/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 3b5644b

Please sign in to comment.