From fb9d463dc33bbb9760b096ad99833820f995cdf0 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 17 Mar 2026 17:37:17 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index e102137..7d95886 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -12,6 +12,7 @@ Features: - Query APIs for UI """ import asyncio +from functools import partial import yaml from random import randint from appPublic.log import debug, exception, error, info @@ -595,8 +596,10 @@ where instance_id=${instance_id}$ await sor.U('node_execution', { 'id': ne['id'], 'status': 'failed', + 'output': str(e), 'stopping_at': timestampstr() }) + exception(f'执行失败:{e}') async def list_human_tasks(self, org_id, user_roles): env = ServerEnv()