    def _batch(self, batch_inputs, profiler: bool, tracer: bool, trace_edges: list = None):
        """
        Run batch call with debug option.
        """
        graph_res = []
        time_profilers = []
        data_queues = []
        for inputs in batch_inputs:
            time_profiler = TimeProfiler(False) if time_profilers is None else TimeProfiler(True)
            gh = _Graph(self._dag_repr.nodes, self._dag_repr.edges, self._operator_pool, self._thread_pool, time_profiler, trace_edges)

            if profiler:
                time_profilers.append(gh.time_profiler)
            if tracer:
                data_queues.append(gh.data_queues)
            if gh.input_col_size == 1:
                inputs = (inputs, )
            graph_res.append(gh.async_call(inputs))

        rets = []
        for gf in graph_res:
            ret = gf.result()
            rets.append(ret)
        return rets, time_profilers if time_profilers else None, data_queues if data_queues else None
Run batch call with debug option.
towhee/runtime/runtime_pipeline.py