incorrect assignment of txid in the precommit (#1205)

kwilteam · Jan 9, 2025 · ebd06c0 · ebd06c0
1 parent a45e3d8
commit ebd06c0
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/node/pg/db.go b/node/pg/db.go
@@ -556,11 +556,12 @@ func (db *DB) precommit(ctx context.Context, changes chan<- any) ([]byte, error)
 		return nil, errors.New("replication connection is down")
 	}
 
-	db.txid = random.String(10)
-	sqlPrepareTx := fmt.Sprintf(`PREPARE TRANSACTION '%s'`, db.txid)
+	txid := random.String(10)
+	sqlPrepareTx := fmt.Sprintf(`PREPARE TRANSACTION '%s'`, txid)
 	if _, err := db.tx.Exec(ctx, sqlPrepareTx); err != nil {
 		return nil, err
 	}
+	db.txid = txid
 
 	logger.Debugf("prepared transaction %q", db.txid)