diff --git a/src/backend/langflow/graph/vertex/types.py b/src/backend/langflow/graph/vertex/types.py index 5c6aaecf8..f8d4ae1e4 100644 --- a/src/backend/langflow/graph/vertex/types.py +++ b/src/backend/langflow/graph/vertex/types.py @@ -405,7 +405,7 @@ class ChatVertex(StatelessVertex): await super()._run(*args, **kwargs) async def stream(self): - iterator = self.params.get("message", None) + iterator = self.params.get("input_value", None) if not isinstance(iterator, (AsyncIterator, Iterator)): raise ValueError("The message must be an iterator or an async iterator.") is_async = isinstance(iterator, AsyncIterator)