class_docstr: Test RuntimePipeline in Pipeline
class_docstr_tok: ["Test","RuntimePipeline","in","Pipeline"]
code: def test_map_schema(self):
      def add(*inputs):
          re = 0
          for i in inputs:
              re += i
          return re
  
      p_1 = (
          pipe.input("x", "y", "z")
          .map(("x", "y", "z"), "z", add)
          .output("z")
      )
      p = (
          pipe.input("x")
          .map("x", "y", p_1)
          .map("y", "y", lambda x: x * 10)
          .output("y")
      )
      res = p(1).get()
      self.assertEqual(res, [10])
  
      p_2 = (
          pipe.input("a")
          .map("a", "a", add)
          .map("a", "a", lambda x: x * 10)
          .output("a")
      )
      p = (
          pipe.input("x", "y", "z")
          .map(("x", "y", "z"), "y", p_2)
          .map("x", "z", lambda x: x * 10)
          .output("y", "z")
      )
      res = p(1, 2, 3).get()
      self.assertEqual(res, [60, 10])
  
file_path: towhee/tests/unittests/runtime/test_dag_pipeline.py
imports: import unittest
  from towhee import pipe
label_desc: Use image node_id 3 for calling the TestDAGPipeline obj's underlying member method code with example usage: obj.test_map_schema() and returns: re