diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index feeab9e..290d585 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -420,7 +420,7 @@ where status in ['pending', 'running'] 'instance_id': inst['id'] }) return True - some = extract_some_value(join): + some = extract_some_value(join) sql = """select * from node_transfer where instance_id=${instance_id}$ and to_node_id = ${node_id}$"""