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:44:31 +08:00
parent 40884a97dc
commit 3228ccd246
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dagflow/dagflow.py
View File

@ -420,7 +420,7 @@ where status in ['pending', 'running']
'instance_id': inst['id'] 'instance_id': inst['id']
}) })
return True return True
some = extract_some_value(join): some = extract_some_value(join)
sql = """select * from node_transfer sql = """select * from node_transfer
where instance_id=${instance_id}$ where instance_id=${instance_id}$
and to_node_id = ${node_id}$""" and to_node_id = ${node_id}$"""