diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index d941104..ba7d5d7 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -371,7 +371,7 @@ where backid=${backid}$
 					'type': node['type'],
 					'inst_round': inst.round,
 					'org_id': inst.org_id,
-					'node_id': node['id'],
+					'node_id': node_id,
 					'input_ctx': node.get('input_ctx'),
 					'output_ctx': node.get('output_ctx'),
 					'status': 'pending',