@@ -492,9 +492,10 @@ def _cluster_info_state_get(self, name: str) -> Optional[Any]:
492492 result = self ._is_leader_retry (self ._query , self .cluster_info_query )[0 ]
493493 cluster_info_state = dict (zip (['timeline' , 'wal_position' , 'replay_lsn' ,
494494 'receive_lsn' , 'replay_paused' , 'pg_control_timeline' ,
495- 'received_tli' , 'write_location' , 'latest_end_lsn' , 'slot_name' , 'conninfo' ,
496- 'receiver_state' , 'restore_command' , 'slots' , 'synchronous_commit' ,
497- 'synchronous_standby_names' , 'pg_stat_replication' ], result ))
495+ 'received_tli' , 'write_location' , 'latest_end_lsn' , 'slot_name' ,
496+ 'conninfo' , 'receiver_state' , 'restore_command' , 'slots' ,
497+ 'synchronous_commit' , 'synchronous_standby_names' ,
498+ 'pg_stat_replication' ], result ))
498499 if self ._should_query_slots and self .can_advance_slots :
499500 cluster_info_state ['slots' ] = \
500501 self .slots_handler .process_permanent_slots (cluster_info_state ['slots' ])
@@ -1278,7 +1279,7 @@ def timeline_wal_position(self) -> Tuple[int, int, Optional[int], Optional[int],
12781279 pg_control_timeline = self ._cluster_info_state_get ('pg_control_timeline' )
12791280 else :
12801281 timeline , wal_position , replay_lsn , receive_lsn , _ , \
1281- pg_control_timeline , _ , write_location , latest_end_lsn = \
1282+ pg_control_timeline , _ , write_location , latest_end_lsn = \
12821283 self ._query (self .cluster_info_query )[0 ][:9 ]
12831284 receive_lsn = max (receive_lsn or 0 , write_location or 0 )
12841285
0 commit comments