    def test_discontinuous_timestamp(self):
        """
        0s --->4s     81s ---> 99s
        time_range_sec: 10s
        time_step_sec: 5s
        """
        buf = _TimeWindowBuffer(10, 5)
        data = [(i, i * 1000) for i in range(100) if i < 3 or i > 91]

        ret = [
            [0, 1, 2],
            [92, 93, 94, 95, 96, 97, 98, 99],
            [95, 96, 97, 98, 99]
        ]
        index = 0
        for item in data:
            if buf(item[0], item[1]):
                self.assertEqual(buf.data, ret[index])
                buf = buf.next()
                index += 1
        while buf and buf.data:
            self.assertEqual(buf.data, ret[index])
            buf = buf.next()
            index += 1
0s --->4s     81s ---> 99s
time_range_sec: 10s
time_step_sec: 5s
tests/unittests/runtime/test_time_window_node.py