diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index e19fdcc..97bc9ba 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -359,9 +359,9 @@ where backid=${backid}$ async def run_auto_task(self, ne): env = ServerEnv() - users = await env.get_org_users(ne.orgid) + users = await env.get_org_users(ne.org_id) if not users: - debug(f'{orgid=} 没有用户') + debug(f'{ne.org_id=} 没有用户') return sub_ctx = self.build_node_input_ctx(inst, ne) try: