diff --git a/rw_core/core/transaction.go b/rw_core/core/transaction.go
index b2d01a4..11f3d4e 100644
--- a/rw_core/core/transaction.go
+++ b/rw_core/core/transaction.go
@@ -247,6 +247,7 @@
 	var res int
 
 	events := ctx.kvClient.Watch(c.txnKey)
+	defer ctx.kvClient.CloseWatch(c.txnKey, events)
 
 	for {
 		select {