class_docstr: Manage the pipeline and runs it as a single instance.
  
  
  Args:
      dag_dict(`Dict`): The DAG Dictionary from the user pipeline.
      max_workers(`int`): The maximum number of threads.
class_docstr_tok: ["Manage","the","pipeline","and","runs","it","as","a","single","instance",".","Args",":","dag_dict","(","`","Dict","`",")",":","The","DAG","Dictionary","from","the","user","pipeline",".","max_workers","(","`","int","`",")",":","The","maximum","number","of","threads","."]
code: def _get_trace_edges(self, trace_nodes):
      def _set_false(idx):
          trace_edges[idx] = False
  
      trace_edges = dict((id, True) for id in self.dag_repr.edges)
      for node in self.dag_repr.nodes.values():
          if node.name not in trace_nodes:
              _ = [_set_false(i) for i in node.out_edges]
  
      return trace_edges
  
imports: import re
  from typing import Dict, Any, Union, Tuple, List
  from concurrent.futures import ThreadPoolExecutor
  from towhee.tools import visualizers
  from towhee.utils.log import engine_log
  from .operator_manager import OperatorPool
  from .data_queue import DataQueue
  from .dag_repr import DAGRepr
  from .nodes import create_node, NodeStatus
  from .node_repr import NodeRepr
  from .time_profiler import TimeProfiler, Event
label_desc: Use image node_id 10 for calling the RuntimePipeline obj's underlying member method code with example usage: obj._get_trace_edges(trace_nodes) and returns: trace_edges