Function pipeline

dali/test/python/operator_1/test_inflate.py:109–112

()

    @pipeline_def
    def pipeline():
        sample, deflated, shape = fn.external_source(source=source, batch=True, num_outputs=3)
        inflated = op(deflated.gpu(), shape=shape, dtype=dtype)
        return inflated, sample

    with chck_ctx:
        pipe = pipeline(batch_size=batch_size, num_threads=4, device_id=0)