community: Bump ruff version to 0.9 (#29206)

Co-authored-by: Erick Friis <[email protected]>

Author: 2 people

libs/community/langchain_community/agent_toolkits/nla/tool.py

@@ -30,7 +30,7 @@ def from_open_api_endpoint_chain(
             The API endpoint tool.
         """
         expanded_name = (
-            f'{api_title.replace(" ", "_")}.{chain.api_operation.operation_id}'
+            f"{api_title.replace(' ', '_')}.{chain.api_operation.operation_id}"
         )
         description = (
             f"I'm an AI from {api_title}. Instruct what you want,"

libs/community/langchain_community/callbacks/fiddler_callback.py

@@ -100,7 +100,7 @@ def __init__(
 
         if self.project not in self.fiddler_client.get_project_names():
             print(  # noqa: T201
-                f"adding project {self.project}." "This only has to be done once."
+                f"adding project {self.project}.This only has to be done once."
             )
             try:
                 self.fiddler_client.add_project(self.project)

libs/community/langchain_community/callbacks/manager.py

@@ -61,9 +61,9 @@ def get_openai_callback() -> Generator[OpenAICallbackHandler, None, None]:
 
 
 @contextmanager
-def get_bedrock_anthropic_callback() -> (
-    Generator[BedrockAnthropicTokenUsageCallbackHandler, None, None]
-):
+def get_bedrock_anthropic_callback() -> Generator[
+    BedrockAnthropicTokenUsageCallbackHandler, None, None
+]:
     """Get the Bedrock anthropic callback handler in a context manager.
     which conveniently exposes token and cost information.
 

libs/community/langchain_community/callbacks/streamlit/streamlit_callback_handler.py

@@ -211,9 +211,9 @@ def on_agent_action(
     def complete(self, final_label: Optional[str] = None) -> None:
         """Finish the thought."""
         if final_label is None and self._state == LLMThoughtState.RUNNING_TOOL:
-            assert (
-                self._last_tool is not None
-            ), "_last_tool should never be null when _state == RUNNING_TOOL"
+            assert self._last_tool is not None, (
+                "_last_tool should never be null when _state == RUNNING_TOOL"
+            )
             final_label = self._labeler.get_tool_label(
                 self._last_tool, is_complete=True
             )

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

@@ -467,7 +467,7 @@ async def amake_request(
                         logger.warning(f"Pebblo Server: Error {response.status}")
                     elif response.status >= HTTPStatus.BAD_REQUEST:
                         logger.warning(
-                            f"Pebblo received an invalid payload: " f"{response.text}"
+                            f"Pebblo received an invalid payload: {response.text}"
                         )
                     elif response.status != HTTPStatus.OK:
                         logger.warning(

libs/community/langchain_community/chat_loaders/facebook_messenger.py

@@ -37,7 +37,7 @@ def lazy_load(self) -> Iterator[ChatSession]:
             if "content" not in m:
                 logger.info(
                     f"""Skipping Message No.
-                    {index+1} as no content is present in the message"""
+                    {index + 1} as no content is present in the message"""
                 )
                 continue
             messages.append(

libs/community/langchain_community/chat_message_histories/neo4j.py

@@ -87,7 +87,7 @@ def messages(self) -> List[BaseMessage]:
         query = (
             f"MATCH (s:`{self._node_label}`)-[:LAST_MESSAGE]->(last_message) "
             "WHERE s.id = $session_id MATCH p=(last_message)<-[:NEXT*0.."
-            f"{self._window*2}]-() WITH p, length(p) AS length "
+            f"{self._window * 2}]-() WITH p, length(p) AS length "
             "ORDER BY length DESC LIMIT 1 UNWIND reverse(nodes(p)) AS node "
             "RETURN {data:{content: node.content}, type:node.type} AS result"
         )

libs/community/langchain_community/chat_message_histories/sql.py

@@ -177,9 +177,9 @@ def __init__(
             engine_args: Additional configuration for creating database engines.
             async_mode: Whether it is an asynchronous connection.
         """
-        assert not (
-            connection_string and connection
-        ), "connection_string and connection are mutually exclusive"
+        assert not (connection_string and connection), (
+            "connection_string and connection are mutually exclusive"
+        )
         if connection_string:
             global _warned_once_already
             if not _warned_once_already:

libs/community/langchain_community/chat_models/bedrock.py

@@ -110,9 +110,9 @@ def _format_anthropic_messages(
 
         if not isinstance(message.content, str):
             # parse as dict
-            assert isinstance(
-                message.content, list
-            ), "Anthropic message content must be str or list of dicts"
+            assert isinstance(message.content, list), (
+                "Anthropic message content must be str or list of dicts"
+            )
 
             # populate content
             content = []

libs/community/langchain_community/chat_models/deepinfra.py

@@ -468,8 +468,7 @@ def _handle_status(self, code: int, text: Any) -> None:
             raise ValueError(f"DeepInfra received an invalid payload: {text}")
         elif code != 200:
             raise Exception(
-                f"DeepInfra returned an unexpected response with status "
-                f"{code}: {text}"
+                f"DeepInfra returned an unexpected response with status {code}: {text}"
             )
 
     def _url(self) -> str: