release: 0.3.28 (#266)

Author: mdrxy

libs/community/Makefile

@@ -59,12 +59,6 @@ format format_diff:
 	[ "$(PYTHON_FILES)" = "" ] || uv run --group typing --group lint ruff format $(PYTHON_FILES)
 	[ "$(PYTHON_FILES)" = "" ] || uv run --group typing --group lint ruff check --select I --fix $(PYTHON_FILES)
 
-spell_check:
-	uv run --group typing --group lint codespell --toml pyproject.toml
-
-spell_fix:
-	uv run --group typing --group lint codespell --toml pyproject.toml -w
-
 ######################
 # HELP
 ######################

libs/community/langchain_community/cache.py

@@ -485,7 +485,7 @@ def lookup(self, prompt: str, llm_string: str) -> Optional[RETURN_VAL_TYPE]:
         # Read from a Redis HASH
         try:
             results = self.redis.hgetall(self._key(prompt, llm_string))
-            return self._get_generations(results)  # type: ignore[arg-type]
+            return self._get_generations(results)
         except Exception as e:
             logger.error(f"Redis lookup failed: {e}")
             return None
@@ -558,7 +558,7 @@ async def alookup(self, prompt: str, llm_string: str) -> Optional[RETURN_VAL_TYP
         """Look up based on prompt and llm_string. Async version."""
         try:
             results = await self.redis.hgetall(self._key(prompt, llm_string))
-            return self._get_generations(results)  # type: ignore[arg-type]
+            return self._get_generations(results)
         except Exception as e:
             logger.error(f"Redis async lookup failed: {e}")
             return None

libs/community/langchain_community/chains/pebblo_retrieval/utilities.py

@@ -50,7 +50,7 @@ def get_runtime() -> Tuple[Framework, Runtime]:
     """
     runtime_env = get_runtime_environment()
     framework = Framework(
-        name="langchain", version=runtime_env.get("library_version", None)
+        name="langchain", version=runtime_env.get("library_version", "unknown")
     )
     uname = platform.uname()
     runtime = Runtime(

libs/community/langchain_community/chat_loaders/utils.py

@@ -26,7 +26,7 @@ def merge_chat_runs_in_session(
             text = ""
             for content in message.content:
                 if isinstance(content, dict):
-                    text += content.get("text", None)
+                    text += content.get("text", "") or ""
                 else:
                     text += content
             message.content = text

libs/community/langchain_community/chat_models/azureml_endpoint.py

@@ -311,7 +311,7 @@ def _stream(
         ]
         params = {"stream": True, "stop": stop, "model": None, **kwargs}
 
-        default_chunk_class = AIMessageChunk
+        default_chunk_class: Type[BaseMessageChunk] = AIMessageChunk
         for chunk in client.chat.completions.create(messages=message_dicts, **params):
             if not isinstance(chunk, dict):
                 chunk = chunk.dict()
@@ -366,7 +366,7 @@ async def _astream(
         ]
         params = {"stream": True, "stop": stop, "model": None, **kwargs}
 
-        default_chunk_class = AIMessageChunk
+        default_chunk_class: Type[BaseMessageChunk] = AIMessageChunk
         async for chunk in await async_client.chat.completions.create(
             messages=message_dicts,
             **params,

libs/community/langchain_community/chat_models/baichuan.py

@@ -473,7 +473,7 @@ def _stream(
         res = self._chat(messages, stream=True, **kwargs)
         if res.status_code != 200:
             raise ValueError(f"Error from Baichuan api response: {res}")
-        default_chunk_class = AIMessageChunk
+        default_chunk_class: Type[BaseMessageChunk] = AIMessageChunk
         for chunk in res.iter_lines():
             chunk = chunk.decode("utf-8").strip("\r\n")
             parts = chunk.split("data: ", 1)
@@ -490,7 +490,7 @@ def _stream(
                 default_chunk_class = chunk.__class__
                 cg_chunk = ChatGenerationChunk(message=chunk)
                 if run_manager:
-                    run_manager.on_llm_new_token(chunk.content, chunk=cg_chunk)
+                    run_manager.on_llm_new_token(str(chunk.content), chunk=cg_chunk)
                 yield cg_chunk
 
     async def _agenerate(

libs/community/langchain_community/chat_models/coze.py

@@ -192,7 +192,7 @@ def _stream(
             chunk = _convert_delta_to_message_chunk(response["message"])
             cg_chunk = ChatGenerationChunk(message=chunk)
             if run_manager:
-                run_manager.on_llm_new_token(chunk.content, chunk=cg_chunk)
+                run_manager.on_llm_new_token(str(chunk.content), chunk=cg_chunk)
             yield cg_chunk
 
     def _chat(self, messages: List[BaseMessage], **kwargs: Any) -> requests.Response:

libs/community/langchain_community/chat_models/fireworks.py

@@ -208,7 +208,7 @@ def _stream(
         **kwargs: Any,
     ) -> Iterator[ChatGenerationChunk]:
         message_dicts = self._create_message_dicts(messages)
-        default_chunk_class = AIMessageChunk
+        default_chunk_class: Type[BaseMessageChunk] = AIMessageChunk
         params = {
             "model": self.model,
             "messages": message_dicts,
@@ -241,7 +241,7 @@ async def _astream(
         **kwargs: Any,
     ) -> AsyncIterator[ChatGenerationChunk]:
         message_dicts = self._create_message_dicts(messages)
-        default_chunk_class = AIMessageChunk
+        default_chunk_class: Type[BaseMessageChunk] = AIMessageChunk
         params = {
             "model": self.model,
             "messages": message_dicts,
@@ -263,7 +263,7 @@ async def _astream(
                 message=chunk, generation_info=generation_info
             )
             if run_manager:
-                await run_manager.on_llm_new_token(token=chunk.text, chunk=cg_chunk)
+                await run_manager.on_llm_new_token(token=cg_chunk.text, chunk=cg_chunk)
             yield cg_chunk
 
 

libs/community/langchain_community/chat_models/gpt_router.py

@@ -334,7 +334,7 @@ def _stream(
 
             if run_manager:
                 run_manager.on_llm_new_token(
-                    token=chunk.message.content, chunk=chunk.message
+                    token=str(chunk.message.content), chunk=chunk
                 )
 
             yield chunk
@@ -367,7 +367,7 @@ async def _astream(
 
             if run_manager:
                 await run_manager.on_llm_new_token(
-                    token=chunk.message.content, chunk=chunk.message
+                    token=str(chunk.message.content), chunk=chunk
                 )
 
             yield chunk

libs/community/langchain_community/chat_models/hunyuan.py

@@ -228,7 +228,7 @@ def _stream(
     ) -> Iterator[ChatGenerationChunk]:
         res = self._chat(messages, **kwargs)
 
-        default_chunk_class = AIMessageChunk
+        default_chunk_class: Type[BaseMessageChunk] = AIMessageChunk
         for chunk in res:
             chunk = chunk.get("data", "")
             if len(chunk) == 0:
@@ -245,7 +245,7 @@ def _stream(
                 default_chunk_class = chunk.__class__
                 cg_chunk = ChatGenerationChunk(message=chunk)
                 if run_manager:
-                    run_manager.on_llm_new_token(chunk.content, chunk=cg_chunk)
+                    run_manager.on_llm_new_token(str(chunk.content), chunk=cg_chunk)
                 yield cg_chunk
 
     def _chat(self, messages: List[BaseMessage], **kwargs: Any) -> Any: