Function pipe

dali/test/python/decoder/test_numpy.py:38–43

()

    @pipeline_def(batch_size=1, num_threads=1)
    def pipe():
        encoded_npy = fn.external_source(
            source=box_source(data), num_outputs=1, batch=False, ndim=1, dtype=DALIDataType.UINT8
        )
        decoded = fn.decoders.numpy(encoded_npy)
        return decoded

    p = pipe()
    p.build()