class_docstr: Test case of invalid pipe interface 
docstr: target: test window_all() API for invalid scenario
  method: input/output_schema type invalid
  expected: raise exception
docstr_tok: ["target",":","test","window_all","(",")","API","for","invalid","scenario","method",":","input\/output_schema","type","invalid","expected",":","raise","exception"]
code: def test_data_collection_window_all_invalid(self):
      """
      target: test window_all() API for invalid scenario
      method: input/output_schema type invalid
      expected: raise exception
      """
      try:
          towhee.pipe.input("n1", "n2").flat_map(
              ("n1", "n2"),
              ("n1", "n2"),
              lambda x, y: [(a, b) for a, b in zip(x, y)],
          ).window_all(
              ("n1", "n2"), ("s1", "s"), lambda x, y: (sum(x), sum(y))
          ).output(
              "s1", "s2"
          )
      except Exception as e:
          assert "not declared" in str(e)
  
      return True
  
imports: import sys
  import towhee
  import time
  import threading
  import numpy
  import random
  import operator
  from common import common_func
  from towhee import pipe, ops
label_desc: Use image node_id 7 for calling the TestPipeAPIsInvalid obj's underlying member method code with example usage: obj.test_data_collection_window_all_invalid() and returns: True