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-16 17:15:49 +08:00
parent d943835cb8
commit bf5aca20b2
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dagflow/dagflow.py
View File

@ -344,7 +344,7 @@ where backid=${backid}$
}) })
async def node_transfer(self, sor, dsl, inst, ne, node, flow_def): async def node_transfer(self, sor, dsl, inst, ne, node, flow_def):
nnode = [] nnodes = []
ctx = json.loads(inst.ctx) ctx = json.loads(inst.ctx)
for edge in dsl.get('edges', []): for edge in dsl.get('edges', []):
if edge['from'] != ne.node_id: if edge['from'] != ne.node_id:
@ -354,19 +354,14 @@ where backid=${backid}$
continue continue
m_on = edge.get('foreach') m_on = edge.get('foreach')
if m_on: if m_on:
ns = DictObject(**{
'sor': sor,
'm_on': m_on,
'ctx': ctx,
'node': node
})
on_array = safe_eval_condition(m_on, ctx) on_array = safe_eval_condition(m_on, ctx)
for e in on_array: for e in on_array:
nnodes.add((edge['to'], str(e))) nnodes.add((edge['to'], str(e)))
else: else:
nnodes.add(edge['to'], None) nnodes.add(edge['to'], None)
for node, ctx_ext in nnodes: for node_id, ctx_ext in nnodes:
node = dsl['nodes'][node_id]
x = await self.is_ok_to_create_new_node_exe(sor, node, edges, inst) x = await self.is_ok_to_create_new_node_exe(sor, node, edges, inst)
if x: if x:
env = ServerEnv() env = ServerEnv()