- 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.