Method __init__

dali/test/python/operator_2/test_python_function.py:558–562

(self, batch_size, num_threads, device_id, _seed)

class AsyncPipeline(Pipeline):
    def __init__(self, batch_size, num_threads, device_id, _seed):
        super().__init__(
            batch_size, num_threads, device_id, seed=_seed, exec_async=True, exec_pipelined=True
        )
        self.op = ops.PythonFunction(function=lambda: numpy.zeros([2, 2, 2]))

    def define_graph(self):
        return self.op()