@@ -110,7 +110,7 @@ def test_process_permanent_slots(self):
110110 with patch .object (Postgresql , '_query' ) as mock_query :
111111 self .p .reset_cluster_info_state (None )
112112 mock_query .return_value = [(
113- 1 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , None , None ,
113+ 1 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , None , None ,
114114 [{"slot_name" : "ls" , "type" : "logical" , "datoid" : 5 , "plugin" : "b" , "xmin" : 105 ,
115115 "confirmed_flush_lsn" : 12345 , "catalog_xmin" : 105 , "restart_lsn" : 12344 },
116116 {"slot_name" : "blabla" , "type" : "physical" , "datoid" : None , "plugin" : None , "xmin" : 105 ,
@@ -119,7 +119,7 @@ def test_process_permanent_slots(self):
119119
120120 self .p .reset_cluster_info_state (None )
121121 mock_query .return_value = [(
122- 1 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , None , None ,
122+ 1 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , None , None ,
123123 [{"slot_name" : "ls" , "type" : "logical" , "datoid" : 6 , "plugin" : "b" , "xmin" : 105 ,
124124 "confirmed_flush_lsn" : 12345 , "catalog_xmin" : 105 }])]
125125 self .assertEqual (self .p .slots (), {'postgresql0' : 0 })
0 commit comments