diff --git a/src/backend/langflow/api/v1/callback.py b/src/backend/langflow/api/v1/callback.py index 2c6f9000d..7387e1dd5 100644 --- a/src/backend/langflow/api/v1/callback.py +++ b/src/backend/langflow/api/v1/callback.py @@ -123,8 +123,8 @@ class AsyncStreamingLLMCallbackHandler(AsyncCallbackHandler): class StreamingLLMCallbackHandler(BaseCallbackHandler): """Callback handler for streaming LLM responses.""" - def __init__(self, websocket): - self.websocket = websocket + def __init__(self, client_id: str): + self.client_id = client_id def on_llm_new_token(self, token: str, **kwargs: Any) -> None: resp = ChatResponse(message=token, type="stream", intermediate_steps="")