@@ -1054,7 +1054,7 @@ def test_the_same_port(self):
10541054 self .assertTrue (node ._should_free_port )
10551055 self .assertEqual (type (node .port ), int )
10561056 node_port_copy = node .port
1057- self .assertEqual (node .safe_psql ("SELECT 1;" ), b'1\n ' )
1057+ self .assertEqual (rm_carriage_returns ( node .safe_psql ("SELECT 1;" ) ), b'1\n ' )
10581058
10591059 with get_new_node (port = node .port ) as node2 :
10601060 self .assertEqual (type (node2 .port ), int )
@@ -1069,7 +1069,7 @@ def test_the_same_port(self):
10691069 # node is still working
10701070 self .assertEqual (node .port , node_port_copy )
10711071 self .assertTrue (node ._should_free_port )
1072- self .assertEqual (node .safe_psql ("SELECT 3;" ), b'3\n ' )
1072+ self .assertEqual (rm_carriage_returns ( node .safe_psql ("SELECT 3;" ) ), b'3\n ' )
10731073
10741074 class tagPortManagerProxy :
10751075 sm_prev_testgres_reserve_port = None
@@ -1175,7 +1175,7 @@ def test_port_rereserve_during_node_start(self):
11751175 self .assertTrue (node1 ._should_free_port )
11761176 self .assertEqual (type (node1 .port ), int ) # noqa: E721
11771177 node1_port_copy = node1 .port
1178- self .assertEqual (node1 .safe_psql ("SELECT 1;" ), b'1\n ' )
1178+ self .assertEqual (rm_carriage_returns ( node1 .safe_psql ("SELECT 1;" ) ), b'1\n ' )
11791179
11801180 with __class__ .tagPortManagerProxy (node1 .port , C_COUNT_OF_BAD_PORT_USAGE ):
11811181 assert __class__ .tagPortManagerProxy .sm_DummyPortNumber == node1 .port
@@ -1191,12 +1191,12 @@ def test_port_rereserve_during_node_start(self):
11911191 self .assertEqual (__class__ .tagPortManagerProxy .sm_DummyPortTotalUsage , C_COUNT_OF_BAD_PORT_USAGE )
11921192 self .assertTrue (node2 .is_started )
11931193
1194- self .assertEqual (node2 .safe_psql ("SELECT 2;" ), b'2\n ' )
1194+ self .assertEqual (rm_carriage_returns ( node2 .safe_psql ("SELECT 2;" ) ), b'2\n ' )
11951195
11961196 # node1 is still working
11971197 self .assertEqual (node1 .port , node1_port_copy )
11981198 self .assertTrue (node1 ._should_free_port )
1199- self .assertEqual (node1 .safe_psql ("SELECT 3;" ), b'3\n ' )
1199+ self .assertEqual (rm_carriage_returns ( node1 .safe_psql ("SELECT 3;" ) ), b'3\n ' )
12001200
12011201 def test_port_conflict (self ):
12021202 assert testgres .PostgresNode ._C_MAX_START_ATEMPTS > 1
@@ -1208,7 +1208,7 @@ def test_port_conflict(self):
12081208 self .assertTrue (node1 ._should_free_port )
12091209 self .assertEqual (type (node1 .port ), int ) # noqa: E721
12101210 node1_port_copy = node1 .port
1211- self .assertEqual (node1 .safe_psql ("SELECT 1;" ), b'1\n ' )
1211+ self .assertEqual (rm_carriage_returns ( node1 .safe_psql ("SELECT 1;" ) ), b'1\n ' )
12121212
12131213 with __class__ .tagPortManagerProxy (node1 .port , C_COUNT_OF_BAD_PORT_USAGE ):
12141214 assert __class__ .tagPortManagerProxy .sm_DummyPortNumber == node1 .port
@@ -1233,7 +1233,7 @@ def test_port_conflict(self):
12331233 # node1 is still working
12341234 self .assertEqual (node1 .port , node1_port_copy )
12351235 self .assertTrue (node1 ._should_free_port )
1236- self .assertEqual (node1 .safe_psql ("SELECT 3;" ), b'3\n ' )
1236+ self .assertEqual (rm_carriage_returns ( node1 .safe_psql ("SELECT 3;" ) ), b'3\n ' )
12371237
12381238 def test_simple_with_bin_dir (self ):
12391239 with get_new_node () as node :
0 commit comments