Function pipeline

dali/test/python/test_external_source_parallel.py:1134–1140

()

):
    @dali.pipeline_def
    def pipeline():
        return dali.fn.external_source(
            PerIterShapeSource(shapes),
            batch=False,
            parallel=parallel,
            bytes_per_sample_hint=bytes_per_sample_hint,
        )

    pipe = pipeline(
        batch_size=batch_size,