diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index e066a8a..805eb88 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -335,7 +335,7 @@ where backid=${backid}$
 
 	async def check_instance_completed(self, sor, inst):
 		sql = "select * from node_execution where instance_id=${instance_id} and type='end'"
-		recs = await sor.sqlExe(sql, {'instance_id', inst.id})
+		recs = await sor.sqlExe(sql, {'instance_id': inst.id})
 		if recs:
 			if recs[0].status == 'completed':
 				await sor.U('flow_instance', {