aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--tx.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/tx.go b/tx.go
index 8f70c1b..9be08b5 100644
--- a/tx.go
+++ b/tx.go
@@ -145,6 +145,9 @@ func (tx *Tx) recycle() {
delete(tx.watching, v)
v.watchers.Delete(tx)
}
+ tx.removeRetryProfiles()
+ // I don't think we can reuse Txs, because the "completed" field should/needs to be set
+ // indefinitely after use.
//txPool.Put(tx)
}