class_docstr: PipelineManager Test
class_docstr_tok: ["PipelineManager","Test"]
docstr: _input(map)[(a, b, c)]->sub_op(map)[(a, b)-(d,)]->add_op(map)[(c,)-(e,)]->_output(map)[(d, e)]
docstr_tok: ["_input","(","map",")","[","(","a",",","b",",","c",")","]","-",">","sub_op","(","map",")","[","(","a",",","b",")","-","(","d",",",")","]","-",">","add_op","(","map",")","[","(","c",",",")","-","(","e",",",")","]","-",">","_output","(","map",")","[","(","d",",","e",")","]"]
code: def test_run(self):
      """
      _input(map)[(a, b, c)]->sub_op(map)[(a, b)-(d,)]->add_op(map)[(c,)-(e,)]->_output(map)[(d, e)]
      """
      runtime_pipeline = RuntimePipeline(self.dag_dict)
      result1 = runtime_pipeline(1, 2, 3).get()
      self.assertEqual(result1[0].diff, -1)
      self.assertEqual(result1[1].sum, 13)
  
      result2 = runtime_pipeline(2, 2, -10).get()
      self.assertEqual(result2[0].diff, 0)
      self.assertEqual(result2[1].sum, 0)
  
imports: import copy
  import weakref
  import unittest
  from towhee import pipe
  from towhee.operator import PyOperator
  from towhee.tools.data_visualizer import DataVisualizer
  from towhee.tools.profilers import PerformanceProfiler
  from towhee.runtime.runtime_pipeline import RuntimePipeline
  from towhee.runtime.operator_manager import OperatorRegistry
label_desc: Use image node_id 1 for calling the TestPipelineManager obj's underlying member method code with example usage: obj.test_run() without return types