    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
target: test window_all() API for invalid scenario
method: input/output_schema type invalid
expected: raise exception
tests/testcases/test_data_collection.py