[Data] Remove unused force_reads parameter from `execute_to_iterato…

…r` (ray-project#45487) Signed-off-by: Balaji Veeramani <[email protected]> Signed-off-by: gchurch <[email protected]>
GabeChurch · Jun 11, 2024 · a0d0fd1 · a0d0fd1
1 parent 347e993
commit a0d0fd1
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/python/ray/data/_internal/plan.py b/python/ray/data/_internal/plan.py
@@ -471,7 +471,6 @@ def _get_num_rows_from_blocks_metadata(self, blocks: BlockList) -> Optional[int]
  def execute_to_iterator(
  self,
  allow_clear_input_blocks: bool = True,
- force_read: bool = False,
  ) -> Tuple[
  Iterator[Tuple[ObjectRef[Block], BlockMetadata]],
  DatasetStats,
@@ -484,7 +483,6 @@ def execute_to_iterator(
  Args:
  allow_clear_input_blocks: Whether we should try to clear the input blocks
  for each operator.
- force_read: Whether to force the read operator to fully execute.
 
  Returns:
  Tuple of iterator over output blocks and the executor.
@@ -496,7 +494,7 @@ def execute_to_iterator(
  if self.has_computed_output():
  return (
  self.execute(
- allow_clear_input_blocks, force_read
+ allow_clear_input_blocks, force_read=False
  ).iter_blocks_with_metadata(),
  self._snapshot_stats,
  None,