class_docstr: DataQueue test
code: def _internal_all_scalar(self, DataQueueClass):
      input_que = DataQueueClass(
          [("url", ColumnType.SCALAR), ("image", ColumnType.SCALAR)]
      )
      input_que.put_dict({"url": 1})
      self.assertEqual(input_que.size, 0)
      input_que.put_dict({"image": 1})
      self.assertEqual(input_que.size, 1)
      self.assertEqual(input_que.get(), [1, 1])
      self.assertEqual(input_que.size, 0)
      input_que.seal()
      self.assertEqual(input_que.size, 0)
  
      input_que = DataQueueClass(
          [("url", ColumnType.SCALAR), ("image", ColumnType.SCALAR)]
      )
      input_que.put_dict({"url": 1})
      self.assertEqual(input_que.size, 0)
      input_que.put_dict({"image": 1})
      self.assertEqual(input_que.size, 1)
      input_que.seal()
      self.assertEqual(input_que.size, 1)
      self.assertEqual(input_que.get(), [1, 1])
      self.assertEqual(input_que.size, 0)
  
      input_que = DataQueueClass(
          [("url", ColumnType.SCALAR), ("image", ColumnType.SCALAR)]
      )
      input_que.put_dict({"url": 1})
      self.assertEqual(input_que.size, 0)
      input_que.seal()
      self.assertEqual(input_que.size, 1)
      self.assertEqual(input_que.get(), [1, Empty()])
      self.assertEqual(input_que.size, 0)
  
imports: import unittest
  import threading
  import time
  from functools import partial
  from towhee.runtime.data_queue import DataQueue, ColumnType, Empty
label_desc: Use image node_id 11 for calling the TestDataQueue obj's underlying member method code with example usage: obj._internal_all_scalar(DataQueueClass) without return types