class_docstr: Window
class_docstr_tok: ["Window"]
docstr: inputs:
  
  num1: scalar  -----1----->
  num2: queue   --1-2-3-4--->
  
  params:
      size: 3
      step: 3
  
  outputs:
  
  que1:
  num1: scalar   -----1----->
  num2: queue    --1-2-3-4--->
  sum1: queue    --3-1------>
  sum2: queue    --6-4------>
  
  que2:
  num1: scalar   ------1------>
  sum1: queue    --3-1------>
  sum2: queue    --6-4------>
docstr_tok: ["inputs",":","num1",":","scalar","--","--","-1","--","--","-",">","num2",":","queue","--","1-2-3-4","--","-",">","params",":","size",":","3","step",":","3","outputs",":","que1",":","num1",":","scalar","--","--","-1","--","--","-",">","num2",":","queue","--","1-2-3-4","--","-",">","sum1",":","queue","--","3-1","--","--","--",">","sum2",":","queue","--","6-4","--","--","--",">","que2",":","num1",":","scalar","--","--","--","1","--","--","--",">","sum1",":","queue","--","3-1","--","--","--",">","sum2",":","queue","--","6-4","--","--","--",">"]
code: def test_equal(self):
      """
      inputs:
  
      num1: scalar  -----1----->
      num2: queue   --1-2-3-4--->
  
      params:
          size: 3
          step: 3
  
      outputs:
  
      que1:
      num1: scalar   -----1----->
      num2: queue    --1-2-3-4--->
      sum1: queue    --3-1------>
      sum2: queue    --6-4------>
  
      que2:
      num1: scalar   ------1------>
      sum1: queue    --3-1------>
      sum2: queue    --6-4------>
      """
      exp_ret1 = [
          {"num1": 1, "num2": 1, "sum1": 3, "sum2": 6},
          {"num1": 1, "num2": 2, "sum1": 1, "sum2": 4},
          {"num1": 1, "num2": 3, "sum1": Empty(), "sum2": Empty()},
          {"num1": 1, "num2": 4, "sum1": Empty(), "sum2": Empty()},
      ]
  
      exp_ret2 = [
          {"num1": 1, "sum1": 3, "sum2": 6},
          {"num1": 1, "sum1": 1, "sum2": 4},
      ]
  
      self._test_function(self.node_info, exp_ret1, exp_ret2)
  
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.nodes._window import _WindowBuffer
  from towhee.runtime.data_queue import DataQueue, ColumnType, Empty
  from towhee.runtime.operator_manager import OperatorPool
label_desc: Use image node_id 3 for calling the TestWindowNode obj's underlying member method code with example usage: obj.test_equal() without return types