diff --git a/dagflow/init.py b/dagflow/init.py index 4e87d1d..e7d4452 100644 --- a/dagflow/init.py +++ b/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):