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()