code: def _get_node_queue():
      q1 = DataQueue([("a", ColumnType.SCALAR)])
      q1.put(([1, 2],))
  
      q2 = DataQueue([("b", ColumnType.QUEUE)], keep_data=True)
      q2.put((1,))
      q2.put((2,))
  
      q3 = DataQueue(
          [("b", ColumnType.QUEUE), ("c", ColumnType.QUEUE)],
          keep_data=True,
      )
      q3.put((1, 2))
      q3.put((2, 3))
  
      q4 = DataQueue(
          [("b", ColumnType.QUEUE), ("d", ColumnType.QUEUE)],
          keep_data=True,
      )
      q4.put((1, 3))
      q4.put((2, 4))
  
      q5 = DataQueue(
          [("b", ColumnType.QUEUE), ("e", ColumnType.QUEUE)],
          keep_data=True,
      )
      q5.put((1, 4))
      q5.put((2, 5))
  
      q6 = DataQueue([("c", ColumnType.QUEUE)], keep_data=True)
      q6.put((2,))
      q6.put((3,))
  
      q7 = DataQueue([("d", ColumnType.QUEUE)], keep_data=True)
      q7.put((3,))
      q7.put((4,))
  
      q8 = DataQueue(
          [("b", ColumnType.QUEUE), ("e", ColumnType.QUEUE)],
          keep_data=True,
      )
      q8.put((1, 4))
      q8.put((2, 5))
  
      q9 = DataQueue(
          [
              ("b", ColumnType.QUEUE),
              ("c", ColumnType.QUEUE),
              ("d", ColumnType.QUEUE),
              ("e", ColumnType.QUEUE),
          ],
          keep_data=True,
      )
      q9.put((1, 2, 3, 4))
      q9.put((2, 3, 4, 5))
  
      q = {
          "_input": {"in": [q1], "op_input": ["a"], "out": [q1]},
          "lambda-0": {
              "in": [q1],
              "op_input": ["a"],
              "out": [q2, q2, q2],
          },
          "lambda-1": {"in": [q2], "op_input": ["b"], "out": [q3]},
          "lambda-2": {"in": [q2], "op_input": ["b"], "out": [q4]},
          "lambda-3": {"in": [q2], "op_input": ["b"], "out": [q5]},
          "concat-4": {
              "in": [q6, q7, q8],
              "op_input": ("e", "d", "c"),
              "out": [q9],
          },
          "_output": {
              "in": [q9],
              "op_input": ["b", "c", "d", "e"],
              "out": [q9],
          },
      }
  
      return q
  
file_path: towhee/tests/unittests/tools/test_data_visualizer.py
imports: import unittest
  from towhee import pipe
  from towhee.tools.data_visualizer import PipeVisualizer
  from towhee.datacollection import DataCollection
  from towhee.runtime.data_queue import DataQueue, ColumnType
label_desc: Use image node_id 2 for calling a global function with example usage: _get_node_queue() and returns: q