ray.data.DatasetPipeline.repeat

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

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.

Parameters

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