diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 1bd9a1e..c482348 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -375,7 +375,7 @@ where backid=${backid}$ "callback":f, "errback": ef }) - asyncio.create_task(env.run_skillagent, params) + asyncio.create_task(env.run_skillagent(params)) except Exception as e: await self.task_error_callback(ne.id, str(e)) # ------------------------------