python/ray/data/impl/lazy_block_list.py
def _iter_block_partition_refs(
        self,
    ) -> Iterator[
        Tuple[ObjectRef[MaybeBlockPartition], ObjectRef[BlockPartitionMetadata]]
    ]:
        """Iterate over the block futures and their corresponding metadata futures.

        This does NOT block on the execution of each submitted task.
        """
        outer = self

        class Iter:
            def __init__(self):
                self._pos = -1

            def __iter__(self):
                return self

            def __next__(self):
                self._pos += 1
                if self._pos < len(outer._tasks):
                    return outer._get_or_compute(self._pos)
                raise StopIteration

        return Iter()
Iterate over the block futures and their corresponding metadata futures.

        This does NOT block on the execution of each submitted task.
        
Iterate over the block futures and their corresponding metadata futures.
This does NOT block on the execution of each submitted task.
Iterate over the block futures and their corresponding metadata futures . This does NOT block on the execution of each submitted task .
def _iter_block_partition_refs(
        self,
    ) -> Iterator[
        Tuple[ObjectRef[MaybeBlockPartition], ObjectRef[BlockPartitionMetadata]]
    ]:
        outer = self
        class Iter:
            def __init__(self):
                self._pos = -1
            def __iter__(self):
                return self
            def __next__(self):
                self._pos += 1
                if self._pos < len(outer._tasks):
                    return outer._get_or_compute(self._pos)
                raise StopIteration
        return Iter()
def _iter_block_partition_refs ( self , ) -> Iterator [ Tuple [ ObjectRef [ MaybeBlockPartition ] , ObjectRef [ BlockPartitionMetadata ] ] ] : outer = self class Iter : def __init__ ( self ) : self . _pos = - 1 def __iter__ ( self ) : return self def __next__ ( self ) : self . _pos += 1 if self . _pos < len ( outer . _tasks ) : return outer . _get_or_compute ( self . _pos ) raise StopIteration return Iter ( )
Iterate over the block futures and their corresponding metadata futures.
Iterate over the block futures and their corresponding metadata futures .
"""Iterate over the block futures and their corresponding metadata futures.

        This does NOT block on the execution of each submitted task.
        """
self