diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index d586dd3..f6c6289 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -369,7 +369,6 @@ where backid=${backid}$ self.self.task_error_callback(ne_id, message) async def run_auto_task(self, ne): - async def run_task( env = ServerEnv() users = await env.get_org_users(ne.org_id) if not users: