fix: tx invalidation was wrong

Stumble · Mar 25, 2020 · 614d8e8 · 614d8e8
1 parent 967796d
commit 614d8e8
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/clients/mysql/txdbexecuter.go b/pkg/clients/mysql/txdbexecuter.go
@@ -32,12 +32,12 @@ func (m *manager) getTxDBExecuter(tx *sql.Tx) *txDBExecuter {
 
 func (s *txDBExecuter) commit() {
 	var wg sync.WaitGroup
-	for _, inval := range s.invalidateFunc {
+	for _, v := range s.invalidateFunc {
 		wg.Add(1)
-		go func() {
+		go func(inval func()) {
 			defer wg.Done()
 			inval()
-		}()
+		}(v)
 	}
 	wg.Wait()
 }