python/ray/data/dataset_pipeline.py
def from_iterable(
        iterable: Iterable[Callable[[], Dataset[T]]],
    ) -> "DatasetPipeline[T]":
        """Create a pipeline from an sequence of Dataset producing functions.

        Args:
            iterable: A finite or infinite-length sequence of functions that
                each produce a Dataset when called.
        """
        if hasattr(iterable, "__len__"):
            length = len(iterable)
        else:
            length = None
        return DatasetPipeline(iterable, length=length)
Create a pipeline from an sequence of Dataset producing functions.

        Args:
            iterable: A finite or infinite-length sequence of functions that
                each produce a Dataset when called.
        
Create a pipeline from an sequence of Dataset producing functions.
Create a pipeline from an sequence of Dataset producing functions .
def from_iterable(
        iterable: Iterable[Callable[[], Dataset[T]]],
    ) -> "DatasetPipeline[T]":
        if hasattr(iterable, "__len__"):
            length = len(iterable)
        else:
            length = None
        return DatasetPipeline(iterable, length=length)
def from_iterable ( iterable : Iterable [ Callable [ [ ] , Dataset [ T ] ] ] , ) -> "DatasetPipeline[T]" : if hasattr ( iterable , "__len__" ) : length = len ( iterable ) else : length = None return DatasetPipeline ( iterable , length = length )
Create a pipeline from an sequence of Dataset producing functions.
Create a pipeline from an sequence of Dataset producing functions .
"""Create a pipeline from an sequence of Dataset producing functions.

        Args:
            iterable: A finite or infinite-length sequence of functions that
                each produce a Dataset when called.
        """
iterable
Iterable[Callable[[], Dataset[T]]]
A finite or infinite-length sequence of functions that
each produce a Dataset when called.
A finite or infinite - length sequence of functions that each produce a Dataset when called .