class_docstr: Test RuntimePipeline in Pipeline
class_docstr_tok: ["Test","RuntimePipeline","in","Pipeline"]
code: def test_time_window(self):
      p = (
          pipe.input("x")
          .flat_map("x", "x", p4)
          .map("x", "y", lambda x: x * 1000)
          .time_window("x", "x", "y", 2, 2, p5)
          .output("x")
      )
  
      res = p(4).to_list()
      self.assertEqual(res, [[10], [50], [40]])
  
file_path: towhee/tests/unittests/runtime/test_dag_pipeline.py
imports: import unittest
  from towhee import pipe
label_desc: Use image node_id 9 for calling the TestDAGPipeline obj's underlying member method code with example usage: obj.test_time_window() without return types