Function pdef

dali/test/python/test_pipeline.py:2185–2188

()

    @pipeline_def(batch_size=bs, num_threads=4, device_id=0, exec_dynamic=True)
    def pdef():
        enc, _ = fn.readers.file(file_root=jpeg_folder)
        img = fn.decoders.image(enc, device="mixed")
        return img, img.cpu()

    pipe = pdef()
    for i in range(10):