diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 1a8d346..017ec61 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -380,7 +380,7 @@ where backid=${backid}$ await sor.C('node_execution', { 'id': id, 'org_id': inst['org_id'], - 'instance_id': inst['id], + 'instance_id': inst['id'], 'node_id': node['id'], 'ctx': json.dumps(ctx, ensure_ascii=False), 'ctx_ext': json.dumps(ctx_ext, ensure_ascii=False),