yumoqing/dagflow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-13 14:54:24 +08:00
parent 7c43ba8880
commit ff74df8fe1
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dagflow/dagflow.py
View File

@ -292,7 +292,7 @@ where backid=${backid}$
async def auto_assign(self, sor, inst, ne, node): async def auto_assign(self, sor, inst, ne, node):
recs = await env.get_org_users(sor, inst.org_id, ne.role) recs = await env.get_org_users(sor, inst.org_id, ne.role)
if recs: if recs:
i = randint(len(recs) - 1) i = randint(0, len(recs) - 1)
await sor.U('node_execution', { await sor.U('node_execution', {
'id':ne.id, 'id':ne.id,
'assignee': recs[i].id 'assignee': recs[i].id
@ -501,7 +501,7 @@ where instance_id=${instance_id}$
def get_engine(): def get_engine():
env = ServerEnv() env = ServerEnv()
cnt = len(env.flow_engines) cnt = len(env.flow_engines)
id = randint(cnt-1) id = randint(0, cnt-1)
return env.flow_engines[id] return env.flow_engines[id]
async def add_new_workflow(request, params_kw={}): async def add_new_workflow(request, params_kw={}):