bugfix

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
 			}