@@ -47,8 +47,8 @@ def initialize_node(working_dir, prefix, port, bin_dir, base_dir):
47
47
pg_node_old = f"pg{ pg_version_old } "
48
48
pg_node_new = f"pg{ pg_version_new } "
49
49
50
- pg_port_old = getenv_or_default ("PGPORTOLD" , "54321" )
51
- pg_port_new = getenv_or_default ("PGPORTNEW" , "54322" )
50
+ pg_port_old = int ( getenv_or_default ("PGPORTOLD" , "54321" ) )
51
+ pg_port_new = int ( getenv_or_default ("PGPORTNEW" , "54322" ) )
52
52
53
53
test_version = getenv_or_default ("TEST_VERSION" , "v8" )
54
54
@@ -94,12 +94,10 @@ def initialize_node(working_dir, prefix, port, bin_dir, base_dir):
94
94
node_old .safe_psql (dbname = pg_database_test , query = "CHECKPOINT" )
95
95
node_old .safe_psql (dbname = pg_database_test , filename = "test/sql/updates/setup.check.sql" )
96
96
97
- # Run new psql over the old node to have the same psql output
98
- node_new .port = pg_port_old
99
- (code , old_out , old_err ) = node_new .psql (
97
+ # Run over the old node to check the output
98
+ (code , old_out , old_err ) = node_old .psql (
100
99
dbname = pg_database_test , filename = "test/sql/updates/post.pg_upgrade.sql"
101
100
)
102
- node_new .port = pg_port_new
103
101
104
102
# Save output to log
105
103
write_bytes_to_file (f"{ working_dir } /post.{ pg_node_old } .log" , old_out )
0 commit comments