DatasetPipeline.repeat(times: Optional[int] = None) ray.data.dataset_pipeline.DatasetPipeline[ray.data.block.T][source]#

Repeat this pipeline a given number or times, or indefinitely.

This operation is only allowed for pipelines of a finite length. An error will be raised for pipelines of infinite length.

Note that every repeat of the pipeline is considered an “epoch” for the purposes of iter_epochs(). If there are multiple repeat calls, the latest repeat takes precedence for the purpose of defining epochs.


times – The number of times to loop over this pipeline, or None to repeat indefinitely.