fix ordering of txn callbacks

sourcenetwork · Jun 10, 2024 · e70d101 · e70d101
1 parent 5ccea09
commit e70d101
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/datastore/txn.go b/datastore/txn.go
@@ -112,23 +112,23 @@ func (t *txn) Commit(ctx context.Context) error {
 		asyncFns = t.successAsyncFns
 	}
 
-	for _, fn := range fns {
-		fn()
-	}
 	for _, fn := range asyncFns {
 		go fn()
 	}
+	for _, fn := range fns {
+		fn()
+	}
 	return err
 }
 
 func (t *txn) Discard(ctx context.Context) {
 	t.t.Discard(ctx)
-	for _, fn := range t.discardFns {
-		fn()
-	}
 	for _, fn := range t.discardAsyncFns {
 		go fn()
 	}
+	for _, fn := range t.discardFns {
+		fn()
+	}
 }
 
 func (t *txn) OnSuccess(fn func()) {