Skip to content

Commit 89950e5

Browse files
committed
Update test script for XTM
1 parent acab04b commit 89950e5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

contrib/pg_xtm/tests/transfers.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ var running = false
3333
func prepare_db() {
3434
var xids [2]int
3535
var csn int64a
36+
nodes := []int{0,1}
3637

3738
conn1, err := pgx.Connect(cfg1)
3839
checkErr(err)
@@ -61,7 +62,7 @@ func prepare_db() {
6162
xids[1] = execQuery(conn2, "select txid_current()")
6263

6364
// register global transaction in DTMD
64-
exec(conn1, "select dtm_global_transaction($1)", xids)
65+
exec(conn1, "select dtm_global_transaction($1)", nodes, xids)
6566

6667
// first global statement
6768
exec(conn1, "select dtm_get_snapshot()")

0 commit comments

Comments
 (0)