    def _call(self, *inputs, profiler: bool, tracer: bool, trace_edges: list = None):
        """
        Run pipeline with debug option.
        """
        time_profiler = TimeProfiler(True) if profiler else TimeProfiler(False)
        graph = _Graph(self._dag_repr.nodes, self._dag_repr.edges, self._operator_pool, self._thread_pool, time_profiler, trace_edges)

        return graph(inputs), [graph.time_profiler] if profiler else None, [graph.data_queues] if tracer else None
Run pipeline with debug option.
towhee/runtime/runtime_pipeline.py