class_docstr: map node test.
class_docstr_tok: ["map","node","test","."]
code: def test_all_scalar(self):
      in_que = DataQueue([("num", ColumnType.SCALAR)])
      in_que.put((1,))
      in_que.seal()
      out_que = DataQueue(
          [("num", ColumnType.SCALAR), ("vec", ColumnType.SCALAR)]
      )
      node = create_node(
          self.node_repr, self.op_pool, [in_que], [out_que]
      )
      self.assertTrue(node.initialize())
      f = self.thread_pool.submit(node.process)
      f.result()
      self.assertTrue(node.status == NodeStatus.FINISHED)
      self.assertTrue(out_que.sealed)
      self.assertEqual(
          out_que.get_dict(),
          {
              "num": 1,
              "vec": 11,
          },
      )
  
imports: import unittest
  import time
  import copy
  import uuid
  from concurrent.futures import ThreadPoolExecutor
  from towhee.runtime.node_repr import NodeRepr
  from towhee.runtime.nodes import create_node, NodeStatus
  from towhee.runtime.data_queue import DataQueue, ColumnType, Empty
  from towhee.runtime.operator_manager import OperatorPool
label_desc: Use image node_id 11 for calling the TestMapNode obj's underlying member method code with example usage: obj.test_all_scalar() without return types