bugfix

dagflow/init.py

@@ -19,12 +19,10 @@ async def run_skillagent(params):
 	i = randint(0,10)
 	await asyncio.sleep(i)
 	if i <= 7:
-		f = params['callback']
 		data = {'data1': 'test'}
 		debug(f'任务模拟完成，返回数据={data}')
 		return data
 	else:
-		f = params['errback']
 		raise Exception('伪造的错误信息')
 
 async def dagbacktask(engines, app):