feat: add clients initialization in validator

libs/community/langchain_community/chat_models/writer.py

@@ -38,8 +38,9 @@
 )
 from langchain_core.outputs import ChatGeneration, ChatGenerationChunk, ChatResult
 from langchain_core.runnables import Runnable
+from langchain_core.utils import get_from_dict_or_env
 from langchain_core.utils.function_calling import convert_to_openai_tool
-from pydantic import BaseModel, ConfigDict, Field
+from pydantic import BaseModel, ConfigDict, Field, model_validator, SecretStr
 
 logger = logging.getLogger(__name__)
 
@@ -66,8 +67,10 @@ class ChatWriter(BaseChatModel):
             )
     """
 
-    client: Any = Field(exclude=True)  #: :meta private:
-    async_client: Any = Field(exclude=True)  #: :meta private:
+    client: Any = Field(default=None, exclude=True)  #: :meta private:
+    async_client: Any = Field(default=None, exclude=True)  #: :meta private:
+    writer_api_key: Optional[SecretStr] = Field(default=None)
+    """Writer API key."""
     model_name: str = Field(default="palmyra-x-004", alias="model")
     """Model name to use."""
     temperature: float = 0.7
@@ -106,6 +109,24 @@ def _default_params(self) -> Dict[str, Any]:
             **self.model_kwargs,
         }
 
+    @model_validator(mode="before")
+    def validate_environment(self, values: Dict) -> Any:
+        """Validates that api key is passed and creates Writer clients."""
+        try:
+            from writerai import Client, AsyncClient
+        except ImportError as e:
+            raise ImportError(
+                "Could not import writerai python package. "
+                "Please install it with `pip install writerai`."
+            ) from e
+
+        if not (values["client"] and values["async_client"]):
+            api_key = get_from_dict_or_env(values, "api_key", "WRITER_API_KEY")
+            values["client"] = Client(api_key=api_key)
+            values["async_client"] = AsyncClient(api_key=api_key)
+
+        return values
+
     def _create_chat_result(self, response: Any) -> ChatResult:
         generations = []
         for choice in response.choices:

libs/community/tests/unit_tests/chat_models/test_writer.py

@@ -105,7 +105,7 @@ def __init__(
         self.usage = usage
         self.choices = choices
 
-
+@pytest.mark.requires("writer-sdk")
 class TestChatWriterCustom:
     """Test case for ChatWriter"""
 
@@ -114,24 +114,16 @@ def test_writer_model_param(self) -> None:
         test_cases: List[dict] = [
             {
                 "model_name": "palmyra-x-004",
-                "client": MagicMock(),
-                "async_client": AsyncMock(),
             },
             {
                 "model": "palmyra-x-004",
-                "client": MagicMock(),
-                "async_client": AsyncMock(),
             },
             {
                 "model_name": "palmyra-x-004",
-                "client": MagicMock(),
-                "async_client": AsyncMock(),
             },
             {
                 "model": "palmyra-x-004",
                 "temperature": 0.5,
-                "client": MagicMock(),
-                "async_client": AsyncMock(),
             },
         ]
 
@@ -423,6 +415,7 @@ class GetWeather(BaseModel):
         assert response.tool_calls[0]["args"]["location"] == "London"
 
 
+@pytest.mark.requires("writer-sdk")
 class TestChatWriterStandart(ChatModelUnitTests):
     """Test case for ChatWriter that inherits from standard LangChain tests."""