class_docstr: Test Nodes
code: def test_simple(self):
      pipe = RuntimePipeline(self.dag)
      nums = [1, 2, 3, 4, 5]
      scalar_num = 4
      ret = pipe(scalar_num, nums)
      self.assertEqual(ret.size, 2)
      self.assertEqual(ret.schema, ["sum"])
      dc = DataCollection(ret)
      self.assertEqual(
          [item.sum for item in dc.to_list()],
          list(
              filter(
                  lambda x: x > 7,
                  list(map(lambda x: x + scalar_num, nums)),
              )
          ),
      )
  
file_path: towhee/tests/unittests/runtime/test_nodes.py
imports: import unittest
  import copy
  import threading
  from towhee.runtime.runtime_pipeline import RuntimePipeline
  from towhee.datacollection.data_collection import DataCollection
label_desc: Use image node_id 1 for calling the TestNodesWithFlatMap obj's underlying member method code with example usage: obj.test_simple() without return types