community: Bump ruff version to 0.9

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:

libs/community/langchain_community/chat_models/konko.py

@@ -179,8 +179,7 @@ def get_available_models(
 
         if models_response.status_code != 200:
             raise ValueError(
-                f"Error getting models from {models_url}: "
-                f"{models_response.status_code}"
+                f"Error getting models from {models_url}: {models_response.status_code}"
             )
 
         return {model["id"] for model in models_response.json()["data"]}

libs/community/langchain_community/chat_models/premai.py

@@ -196,7 +196,10 @@ def _messages_to_prompt_dict(
         elif isinstance(input_msg, HumanMessage):
             if template_id is None:
                 examples_and_messages.append(
-                    {"role": "user", "content": str(input_msg.content)}
+                    {
+                        "role": "user",
+                        "content": str(input_msg.content),
+                    }
                 )
             else:
                 params: Dict[str, str] = {}
@@ -206,12 +209,19 @@ def _messages_to_prompt_dict(
                 )
                 params[str(input_msg.id)] = str(input_msg.content)
                 examples_and_messages.append(
-                    {"role": "user", "template_id": template_id, "params": params}
+                    {
+                        "role": "user",
+                        "template_id": template_id,
+                        "params": params,
+                    }
                 )
         elif isinstance(input_msg, AIMessage):
             if input_msg.tool_calls is None or len(input_msg.tool_calls) == 0:
                 examples_and_messages.append(
-                    {"role": "assistant", "content": str(input_msg.content)}
+                    {
+                        "role": "assistant",
+                        "content": str(input_msg.content),
+                    }
                 )
             else:
                 ai_msg_to_json = {

libs/community/langchain_community/chat_models/writer.py

@@ -277,7 +277,10 @@ def _stream(
             if not delta or not delta.content:
                 continue
             chunk = self._convert_writer_to_langchain(
-                {"role": "assistant", "content": delta.content}
+                {
+                    "role": "assistant",
+                    "content": delta.content,
+                }
             )
             chunk = ChatGenerationChunk(message=chunk)
 
@@ -303,7 +306,10 @@ async def _astream(
             if not delta or not delta.content:
                 continue
             chunk = self._convert_writer_to_langchain(
-                {"role": "assistant", "content": delta.content}
+                {
+                    "role": "assistant",
+                    "content": delta.content,
+                }
             )
             chunk = ChatGenerationChunk(message=chunk)
 

libs/community/langchain_community/chat_models/zhipuai.py

@@ -121,7 +121,7 @@ def _get_jwt_token(api_key: str) -> str:
         import jwt
     except ImportError:
         raise ImportError(
-            "jwt package not found, please install it with" "`pip install pyjwt`"
+            "jwt package not found, please install it with`pip install pyjwt`"
         )
 
     try:

libs/community/langchain_community/document_compressors/dashscope_rerank.py

@@ -89,7 +89,10 @@ def rerank(
         result_dicts = []
         for res in results.output.results:
             result_dicts.append(
-                {"index": res.index, "relevance_score": res.relevance_score}
+                {
+                    "index": res.index,
+                    "relevance_score": res.relevance_score,
+                }
             )
         return result_dicts
 

libs/community/langchain_community/document_compressors/infinity_rerank.py

@@ -101,7 +101,10 @@ def rerank(
         result_dicts = []
         for res in results:
             result_dicts.append(
-                {"index": res.index, "relevance_score": res.relevance_score}
+                {
+                    "index": res.index,
+                    "relevance_score": res.relevance_score,
+                }
             )
 
         result_dicts.sort(key=lambda x: x["relevance_score"], reverse=True)

libs/community/langchain_community/document_compressors/jina_rerank.py

@@ -95,7 +95,10 @@ def rerank(
         result_dicts = []
         for res in results:
             result_dicts.append(
-                {"index": res["index"], "relevance_score": res["relevance_score"]}
+                {
+                    "index": res["index"],
+                    "relevance_score": res["relevance_score"],
+                }
             )
         return result_dicts
 

libs/community/langchain_community/document_loaders/blob_loaders/youtube_audio.py

@@ -21,8 +21,7 @@ def yield_blobs(self) -> Iterable[Blob]:
             import yt_dlp
         except ImportError:
             raise ImportError(
-                "yt_dlp package not found, please install it with "
-                "`pip install yt_dlp`"
+                "yt_dlp package not found, please install it with `pip install yt_dlp`"
             )
 
         # Use yt_dlp to download audio given a YouTube url

libs/community/langchain_community/document_loaders/chm.py

@@ -117,6 +117,10 @@ def load_all(self) -> List[Dict[str, str]]:
         for item in index:
             content = self.load(item["local"])
             res.append(
-                {"name": item["name"], "local": item["local"], "content": content}
+                {
+                    "name": item["name"],
+                    "local": item["local"],
+                    "content": content,
+                }
             )
         return res

libs/community/langchain_community/document_loaders/confluence.py

@@ -649,7 +649,7 @@ def process_attachment(
             from PIL import Image  # noqa: F401
         except ImportError:
             raise ImportError(
-                "`Pillow` package not found, " "please run `pip install Pillow`"
+                "`Pillow` package not found, please run `pip install Pillow`"
             )
 
         # depending on setup you may also need to set the correct path for

libs/community/langchain_community/document_loaders/csv_loader.py

@@ -164,9 +164,13 @@ def __read_file(self, csvfile: TextIOWrapper) -> Iterator[Document]:
                     f"Source column '{self.source_column}' not found in CSV file."
                 )
             content = "\n".join(
-                f"""{k.strip() if k is not None else k}: {v.strip()
-                if isinstance(v, str) else ','.join(map(str.strip, v))
-                if isinstance(v, list) else v}"""
+                f"""{k.strip() if k is not None else k}: {
+                    v.strip()
+                    if isinstance(v, str)
+                    else ",".join(map(str.strip, v))
+                    if isinstance(v, list)
+                    else v
+                }"""
                 for k, v in row.items()
                 if (
                     k in self.content_columns

libs/community/langchain_community/document_loaders/dropbox.py

@@ -54,7 +54,7 @@ def _create_dropbox_client(self) -> Any:
         try:
             from dropbox import Dropbox, exceptions
         except ImportError:
-            raise ImportError("You must run " "`pip install dropbox")
+            raise ImportError("You must run `pip install dropbox")
 
         try:
             dbx = Dropbox(self.dropbox_access_token)
@@ -73,7 +73,7 @@ def _load_documents_from_folder(self, folder_path: str) -> List[Document]:
             from dropbox import exceptions
             from dropbox.files import FileMetadata
         except ImportError:
-            raise ImportError("You must run " "`pip install dropbox")
+            raise ImportError("You must run `pip install dropbox")
 
         try:
             results = dbx.files_list_folder(folder_path, recursive=self.recursive)
@@ -98,7 +98,7 @@ def _load_file_from_path(self, file_path: str) -> Optional[Document]:
         try:
             from dropbox import exceptions
         except ImportError:
-            raise ImportError("You must run " "`pip install dropbox")
+            raise ImportError("You must run `pip install dropbox")
 
         try:
             file_metadata = dbx.files_get_metadata(file_path)

libs/community/langchain_community/document_loaders/mediawikidump.py

@@ -65,7 +65,7 @@ def _load_dump_file(self):  # type: ignore[no-untyped-def]
             import mwxml
         except ImportError as e:
             raise ImportError(
-                "Unable to import 'mwxml'. Please install with" " `pip install mwxml`."
+                "Unable to import 'mwxml'. Please install with `pip install mwxml`."
             ) from e
 
         return mwxml.Dump.from_file(open(self.file_path, encoding=self.encoding))

libs/community/langchain_community/document_loaders/mongodb.py

@@ -98,7 +98,10 @@ async def aload(self) -> List[Document]:
             # Optionally add database and collection names to metadata
             if self.include_db_collection_in_metadata:
                 metadata.update(
-                    {"database": self.db_name, "collection": self.collection_name}
+                    {
+                        "database": self.db_name,
+                        "collection": self.collection_name,
+                    }
                 )
 
             # Extract text content from filtered fields or use the entire document

libs/community/langchain_community/document_loaders/notiondb.py

@@ -126,7 +126,7 @@ def load_page(self, page_summary: Dict[str, Any]) -> Document:
                 value = prop_data["url"]
             elif prop_type == "unique_id":
                 value = (
-                    f'{prop_data["unique_id"]["prefix"]}-{prop_data["unique_id"]["number"]}'
+                    f"{prop_data['unique_id']['prefix']}-{prop_data['unique_id']['number']}"
                     if prop_data["unique_id"]
                     else None
                 )

libs/community/langchain_community/document_loaders/nuclia.py

@@ -19,7 +19,12 @@ def __init__(self, path: str, nuclia_tool: NucliaUnderstandingAPI):
     def load(self) -> List[Document]:
         """Load documents."""
         data = self.nua.run(
-            {"action": "pull", "id": self.id, "path": None, "text": None}
+            {
+                "action": "pull",
+                "id": self.id,
+                "path": None,
+                "text": None,
+            }
         )
         if not data:
             return []

libs/community/langchain_community/document_loaders/oracleadb_loader.py

@@ -82,8 +82,7 @@ def _run_query(self) -> List[Dict[str, Any]]:
             import oracledb
         except ImportError as e:
             raise ImportError(
-                "Could not import oracledb, "
-                "please install with 'pip install oracledb'"
+                "Could not import oracledb, please install with 'pip install oracledb'"
             ) from e
         connect_param = {"user": self.user, "password": self.password, "dsn": self.dsn}
         if self.dsn == self.tns_name:

libs/community/langchain_community/document_loaders/parsers/audio.py

@@ -148,8 +148,7 @@ def __init__(
             import openai
         except ImportError:
             raise ImportError(
-                "openai package not found, please install it with "
-                "`pip install openai`"
+                "openai package not found, please install it with `pip install openai`"
             )
 
         if is_openai_v1():
@@ -278,14 +277,13 @@ def lazy_parse(self, blob: Blob) -> Iterator[Document]:
             import openai
         except ImportError:
             raise ImportError(
-                "openai package not found, please install it with "
-                "`pip install openai`"
+                "openai package not found, please install it with `pip install openai`"
             )
         try:
             from pydub import AudioSegment
         except ImportError:
             raise ImportError(
-                "pydub package not found, please install it with " "`pip install pydub`"
+                "pydub package not found, please install it with `pip install pydub`"
             )
 
         if is_openai_v1():
@@ -402,7 +400,7 @@ def __init__(
             import torch
         except ImportError:
             raise ImportError(
-                "torch package not found, please install it with " "`pip install torch`"
+                "torch package not found, please install it with `pip install torch`"
             )
 
         # Determine the device to use
@@ -533,7 +531,7 @@ def lazy_parse(self, blob: Blob) -> Iterator[Document]:
             from pydub import AudioSegment
         except ImportError:
             raise ImportError(
-                "pydub package not found, please install it with " "`pip install pydub`"
+                "pydub package not found, please install it with `pip install pydub`"
             )
 
         if self.api_key: