Function pipeline

dali/test/python/operator_2/test_random_beta.py:79–86

()

        prefetch_queue_depth=1,
    )
    def pipeline():
        shape_provider = fn.full(1, shape=shape)
        return fn.random.beta(
            shape_provider,
            alpha=alpha,
            beta=beta,
            dtype=dali_dtype,
        )

    p = pipeline()
    batch = [np.array(s) for s in p.run()[0]]