Function pdef_source

dali/test/python/test_pipeline.py:2415–2417

()

    @pipeline_def(batch_size=bs, num_threads=4, device_id=0)
    def pdef_source():
        source = fn.external_source(name="source")
        return source

    pipes = [pdef_regular() for _ in range(5)]
    pipes.append(pdef_source())