class_docstr: PipelineManager Test
class_docstr_tok: ["PipelineManager","Test"]
code: def test_registry_with_pipe(self):
      # pylint: disable=unused-variable
      @register(name="test_rp/add_operator")
      class AddOperator(PyOperator):
          def __init__(self, fac):
              self.factor = fac
  
          def __call__(self, x):
              return self.factor + x
  
      @register(name="test_rp/sub_operator")
      def sub_operator(x, y):
          return x - y
  
      towhee_dag_test = copy.deepcopy(self.dag_dict)
      towhee_dag_test["op1"]["op_info"][
          "operator"
      ] = "test-rp/sub-operator"
      towhee_dag_test["op2"]["op_info"][
          "operator"
      ] = "test-rp/add-operator"
      towhee_dag_test["op2"]["op_info"]["init_args"] = (1,)
      towhee_dag_test["op2"]["op_info"]["init_kws"] = None
      runtime_pipeline = RuntimePipeline(towhee_dag_test)
      result = runtime_pipeline(1, 2, 3).get()
      self.assertEqual(result, [-1, 4])
  
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 6 for calling the TestPipelineManager obj's underlying member method code with example usage: obj.test_registry_with_pipe() and returns: unknown, unknown