jprdonnelly/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-03-28 23:00:25 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'optional-plugin-invoke' into deploy/dev

Browse Source
This commit is contained in:
WH-2099
2026-03-25 12:12:12 +08:00
parent 9d6f9ba6c0 cee2e4ec29
commit 5790cc52bf
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
api/tasks/app_generate/workflow_execute_task.py
View File

@@ -239,13 +239,18 @@ def _resolve_user_for_run(session: Session, workflow_run: WorkflowRun) -> Accoun
def _publish_streaming_response(
response_stream: Generator[str | Mapping[str, Any], None, None], workflow_run_id: str, app_mode: AppMode
response_stream: Generator[str | Mapping[str, Any] | BaseModel, None, None],
workflow_run_id: str,
app_mode: AppMode,
) -> None:
topic = MessageBasedAppGenerator.get_response_topic(app_mode, workflow_run_id)
for event in response_stream:
try:
payload = json.dumps(event)
except TypeError:
if isinstance(event, BaseModel):
payload = json.dumps(event.model_dump(mode="json"), ensure_ascii=False)
else:
payload = json.dumps(event, ensure_ascii=False, default=str)
except (TypeError, ValueError):
logger.exception("error while encoding event")
continue