feat: add HTTPX_TIMEOUT config

python/dify_plugin/config/config.py

@@ -40,6 +40,8 @@ class DifyPluginEnv(BaseSettings):
 
     DIFY_PLUGIN_DAEMON_URL: str = Field(default="http://localhost:5002", description="backwards invocation address")
 
+    HTTPX_TIMEOUT: int = Field(default=5, description="HTTPX timeout in seconds")
+
     model_config = SettingsConfigDict(
         # read from dotenv format config file
         env_file=".env",

python/dify_plugin/file/file.py

@@ -1,9 +1,12 @@
 import httpx
 from pydantic import BaseModel
 
+from dify_plugin.config.config import DifyPluginEnv
 from dify_plugin.file.constants import DIFY_FILE_IDENTITY
 from dify_plugin.file.entities import FileType
 
+_plugin_config = DifyPluginEnv()
+
 
 class File(BaseModel):
     dify_model_identity: str = DIFY_FILE_IDENTITY
@@ -30,7 +33,7 @@ def blob(self) -> bytes:
         """
         if self._blob is None:
             try:
-                response = httpx.get(self.url)
+                response = httpx.get(self.url, timeout=_plugin_config.HTTPX_TIMEOUT)
                 response.raise_for_status()
                 self._blob = response.content
             except httpx.UnsupportedProtocol as e:

python/dify_plugin/plugin.py

@@ -464,6 +464,7 @@ def _execute_request(
             endpoint_id=endpoint_id,
             context=context,
             max_invocation_timeout=self.config.MAX_INVOCATION_TIMEOUT,
+            httpx_timeout=self.config.HTTPX_TIMEOUT,
         )
         response = self.dispatch(session, data)
         if response:

python/examples/jina/models/rerank/rerank.py

@@ -1,6 +1,7 @@
 import httpx
 
 from dify_plugin import RerankModel
+from dify_plugin.config.config import DifyPluginEnv
 from dify_plugin.entities import I18nObject
 from dify_plugin.entities.model import (
     AIModelEntity,
@@ -22,6 +23,8 @@
     InvokeServerUnavailableError,
 )
 
+_plugin_config = DifyPluginEnv()
+
 
 class JinaRerankModel(RerankModel):
     """
@@ -66,6 +69,7 @@ def _invoke(
                     "top_n": top_n,
                 },
                 headers={"Authorization": f"Bearer {credentials.get('api_key')}"},
+                timeout=_plugin_config.HTTPX_TIMEOUT,
             )
             response.raise_for_status()
             results = response.json()