File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -1199,12 +1199,13 @@ def replica_filter(member: Member) -> bool:
11991199 else :
12001200 members = [m for m in members if expected_active (m )]
12011201
1202+ leader_patroni_version = self .leader and self .leader .member .patroni_version
12021203 slots : Dict [str , int ] = self .slots
12031204 ret : Dict [str , Dict [str , Any ]] = {}
12041205 for member in members :
12051206 slot_name = slot_name_from_member_name (member .name )
12061207 lsn = slots .get (slot_name , 0 )
1207- if member .replicatefrom :
1208+ if member .replicatefrom or leader_patroni_version and leader_patroni_version < ( 4 , 0 , 0 ) :
12081209 # `/status` key is maintained by the leader, but `member` may be connected to some other node.
12091210 # In that case, the slot in the leader is inactive and doesn't advance, so we use the LSN
12101211 # reported by the member to advance replication slot LSN.
You can’t perform that action at this time.
0 commit comments