    def test_large(self):
        """
        inputs:

        num1: scalar  -----1----->
        num2: queue   --1-2-3-4--->

        params:
            size: 2
            step: 3

        outputs:

        que1:
        num1: scalar   -----1----->
        num2: queue    --1-2-3-4--->
        sum1: queue    --2-1------>
        sum2: queue    --3-4------>

        que2:
        num1: scalar   ------1------>
        sum1: queue    --2-1------>
        sum2: queue    --3-4------>
        """
        exp_ret1 = [
            {'num1': 1, 'num2': 1, 'sum1': 2, 'sum2': 3},
            {'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': 2, 'sum2': 3},
            {'num1': 1, 'sum1': 1, 'sum2': 4}
        ]
        info = copy.deepcopy(self.node_info)
        info['iter_info']['param']['size'] = 2
        self._test_function(info, exp_ret1, exp_ret2)
inputs:

num1: scalar  -----1----->
num2: queue   --1-2-3-4--->

params:
size: 2
step: 3

outputs:

que1:
num1: scalar   -----1----->
num2: queue    --1-2-3-4--->
sum1: queue    --2-1------>
sum2: queue    --3-4------>

que2:
num1: scalar   ------1------>
sum1: queue    --2-1------>
sum2: queue    --3-4------>
tests/unittests/runtime/test_window_node.py