Function pipeline

dali/test/python/test_external_source_cupy.py:162–163

()

    @pipeline_def
    def pipeline():
        return fn.external_source(source=cb(), device=device, batch=batch_mode, no_copy=no_copy)

    pipe = pipeline(batch_size=batch_size, num_threads=4, device_id=0)
    for _ in range(num_iters):