@@ -827,6 +827,7 @@ def has_raft_quorum(self) -> bool:
827827 raft_host = "127.0.0.1:2222"
828828 try :
829829 raft_status = syncobj_util .executeCommand (raft_host , ["status" ])
830+ logger .debug ("Local raft status: %s" , raft_status )
830831 except UtilityException :
831832 logger .warning ("Has raft quorum: Cannot connect to raft cluster" )
832833 return False
@@ -896,6 +897,16 @@ def get_running_cluster_members(self) -> list[str]:
896897 except Exception :
897898 return []
898899
900+ def log_raft_status (self ) -> None :
901+ """Best-effort dump of local raft status for debugging."""
902+ raft_host = "127.0.0.1:2222"
903+ try :
904+ syncobj_util = TcpUtility (password = self .raft_password , timeout = 3 )
905+ raft_status = syncobj_util .executeCommand (raft_host , ["status" ])
906+ logger .debug ("Local raft status: %s" , raft_status )
907+ except UtilityException :
908+ logger .debug ("Local raft status unavailable" )
909+
899910 def remove_raft_member (self , member_ip : str ) -> None :
900911 """Remove a member from the raft cluster.
901912
@@ -917,6 +928,7 @@ def remove_raft_member(self, member_ip: str) -> None:
917928 raft_host = "127.0.0.1:2222"
918929 try :
919930 raft_status = syncobj_util .executeCommand (raft_host , ["status" ])
931+ logger .debug ("Local raft status: %s" , raft_status )
920932 except UtilityException :
921933 logger .warning ("Remove raft member: Cannot connect to raft cluster" )
922934 raise RemoveRaftMemberFailedError () from None
0 commit comments