estel/dify
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

enhancing logging (#23332)

Browse Source 
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
This commit is contained in:
znn
2025-08-05 08:06:48 +05:30
committed by GitHub
parent 7fe23a0ca6
commit ab78e12089
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
api/core/plugin/impl/base.py
View File

@@ -208,6 +208,7 @@ class BasePluginClient:
except Exception: except Exception:
raise PluginDaemonInnerError(code=rep.code, message=rep.message) raise PluginDaemonInnerError(code=rep.code, message=rep.message)
logger.error("Error in stream reponse for plugin %s", rep.__dict__)
self._handle_plugin_daemon_error(error.error_type, error.message) self._handle_plugin_daemon_error(error.error_type, error.message)
raise ValueError(f"plugin daemon: {rep.message}, code: {rep.code}") raise ValueError(f"plugin daemon: {rep.message}, code: {rep.code}")
if rep.data is None: if rep.data is None:

4
api/core/plugin/impl/exc.py
View File

@@ -2,6 +2,8 @@ from collections.abc import Mapping
from pydantic import TypeAdapter from pydantic import TypeAdapter
from extensions.ext_logging import get_request_id
class PluginDaemonError(Exception): class PluginDaemonError(Exception):
"""Base class for all plugin daemon errors.""" """Base class for all plugin daemon errors."""
@@ -11,7 +13,7 @@ class PluginDaemonError(Exception):
def __str__(self) -> str: def __str__(self) -> str:
# returns the class name and description # returns the class name and description
return f"{self.__class__.__name__}: {self.description}" return f"req_id: {get_request_id()} {self.__class__.__name__}: {self.description}"
class PluginDaemonInternalError(PluginDaemonError): class PluginDaemonInternalError(PluginDaemonError):