From 66a5b7e7f6f6d671489d226dc9c8c310dd323000 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 17 Mar 2026 17:41:48 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 7d95886..e19fdcc 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -359,7 +359,7 @@ where backid=${backid}$ async def run_auto_task(self, ne): env = ServerEnv() - users = get_org_users(ne.orgid) + users = await env.get_org_users(ne.orgid) if not users: debug(f'{orgid=} 没有用户') return @@ -369,6 +369,8 @@ where backid=${backid}$ ef = partial(self.task_error_callback, ne.id) params = { prompt: sub_ctx, + callerid: users[0].id, + callerorgid: users[0].orgid, callback:f, errback: ef }