bugfix

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