Function test_pipe

dali/test/python/test_external_source_dali.py:881–885

()

    @pipeline_def(batch_size=4, device_id=0, num_threads=4)
    def test_pipe():
        src_0 = fn.external_source(source=my_source, batch=False)
        src_1 = fn.external_source(source=SourceClass(2), batch=False)
        src_2 = fn.external_source(source=SourceClassWithoutInfo(42), batch=False)
        return src_0, src_1, src_2

    pipe = test_pipe()
    out0, out1, out2 = pipe.run()