opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-26 18:27:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'fix/chore-fix' into dev/plugin-deploy

Browse Source
This commit is contained in:
Yeuoly 2024-11-21 17:00:28 +08:00
commit b2fdf4f85f
No known key found for this signature in database
GPG Key ID: A66E7E320FB19F61
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
api/core/plugin/manager/base.py
View File

@ -1,3 +1,4 @@
import inspect
import json import json
import logging import logging
from collections.abc import Callable, Generator from collections.abc import Callable, Generator
@ -139,7 +140,8 @@ class BasePluginManager:
self._handle_plugin_daemon_error(error.error_type, error.message, error.args) self._handle_plugin_daemon_error(error.error_type, error.message, error.args)
raise ValueError(f"{rep.message}, code: {rep.code}") raise ValueError(f"{rep.message}, code: {rep.code}")
if rep.data is None: if rep.data is None:
raise ValueError("got empty data from plugin daemon") frame = inspect.currentframe()
raise ValueError(f"got empty data from plugin daemon: {frame.f_lineno if frame else 'unknown'}")
return rep.data return rep.data
@ -178,7 +180,8 @@ class BasePluginManager:
self._handle_plugin_daemon_error(error.error_type, error.message, error.args) self._handle_plugin_daemon_error(error.error_type, error.message, error.args)
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:
raise ValueError("got empty data from plugin daemon") frame = inspect.currentframe()
raise ValueError(f"got empty data from plugin daemon: {frame.f_lineno if frame else 'unknown'}")
yield rep.data yield rep.data
def _handle_plugin_daemon_error(self, error_type: str, message: str, args: Optional[dict] = None): def _handle_plugin_daemon_error(self, error_type: str, message: str, args: Optional[dict] = None):