Function pipeline

dali/test/python/operator_1/test_affine_transforms.py:814–816

()

        @pipeline_def
        def pipeline():
            mts0, mts1 = fn.external_source(lambda _: (batch0_inp, batch1_inp), num_outputs=2)
            return fn.transforms.combine(fn.per_frame(mts0), fn.per_frame(mts1))

        pipe = pipeline(batch_size=batch_size, num_threads=4, device_id=0)
        pipe.run()