@@ -1054,7 +1054,7 @@ def test_the_same_port(self):
10541054self .assertTrue (node ._should_free_port )
10551055self .assertEqual (type (node .port ),int )
10561056node_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
10591059with get_new_node (port = node .port )as node2 :
10601060self .assertEqual (type (node2 .port ),int )
@@ -1069,7 +1069,7 @@ def test_the_same_port(self):
10691069# node is still working
10701070self .assertEqual (node .port ,node_port_copy )
10711071self .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
10741074class tagPortManagerProxy :
10751075sm_prev_testgres_reserve_port = None
@@ -1175,7 +1175,7 @@ def test_port_rereserve_during_node_start(self):
11751175self .assertTrue (node1 ._should_free_port )
11761176self .assertEqual (type (node1 .port ),int )# noqa: E721
11771177node1_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
11801180with __class__ .tagPortManagerProxy (node1 .port ,C_COUNT_OF_BAD_PORT_USAGE ):
11811181assert __class__ .tagPortManagerProxy .sm_DummyPortNumber == node1 .port
@@ -1191,12 +1191,12 @@ def test_port_rereserve_during_node_start(self):
11911191self .assertEqual (__class__ .tagPortManagerProxy .sm_DummyPortTotalUsage ,C_COUNT_OF_BAD_PORT_USAGE )
11921192self .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
11971197self .assertEqual (node1 .port ,node1_port_copy )
11981198self .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
12011201def test_port_conflict (self ):
12021202assert testgres .PostgresNode ._C_MAX_START_ATEMPTS > 1
@@ -1208,7 +1208,7 @@ def test_port_conflict(self):
12081208self .assertTrue (node1 ._should_free_port )
12091209self .assertEqual (type (node1 .port ),int )# noqa: E721
12101210node1_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
12131213with __class__ .tagPortManagerProxy (node1 .port ,C_COUNT_OF_BAD_PORT_USAGE ):
12141214assert __class__ .tagPortManagerProxy .sm_DummyPortNumber == node1 .port
@@ -1233,7 +1233,7 @@ def test_port_conflict(self):
12331233# node1 is still working
12341234self .assertEqual (node1 .port ,node1_port_copy )
12351235self .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
12381238def test_simple_with_bin_dir (self ):
12391239with get_new_node ()as node :