Skip to content

Commit 141efaf

Browse files
committed
Don't defer on raft removal
1 parent bcecb8c commit 141efaf

File tree

3 files changed

+3
-8
lines changed

3 files changed

+3
-8
lines changed

src/charm.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -652,11 +652,7 @@ def _on_peer_relation_departed(self, event: RelationDepartedEvent) -> None:
652652
member_ip = self._patroni.get_member_ip(departing_member)
653653
self._patroni.remove_raft_member(member_ip)
654654
except RemoveRaftMemberFailedError:
655-
logger.debug(
656-
"Deferring on_peer_relation_departed: Failed to remove member from raft cluster"
657-
)
658-
event.defer()
659-
return
655+
logger.debug("on_peer_relation_departed: Failed to remove member from raft cluster")
660656
except RetryError:
661657
logger.warning(
662658
f"Early exit on_peer_relation_departed: Cannot get {event.departing_unit.name} member IP"

src/cluster.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -963,8 +963,7 @@ def remove_raft_member(self, member_ip: str) -> None:
963963
raise RemoveRaftMemberFailedError() from None
964964

965965
if not result.startswith("SUCCESS"):
966-
logger.error(f"{result}")
967-
logger.debug("Remove raft member: Remove call not successful")
966+
logger.debug(f"Remove raft member: Remove call not successful with {result}")
968967
raise RemoveRaftMemberFailedError()
969968

970969
@retry(stop=stop_after_attempt(20), wait=wait_exponential(multiplier=1, min=2, max=10))

tests/unit/test_charm.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2176,7 +2176,7 @@ def test_on_peer_relation_departed(harness):
21762176
_get_member_ip.return_value = mock_ip_address
21772177
harness.charm._on_peer_relation_departed(event)
21782178
_remove_raft_member.assert_called_once_with(mock_ip_address)
2179-
event.defer.assert_called_once()
2179+
# event.defer.assert_called_once()
21802180
_updated_synchronous_node_count.assert_not_called()
21812181
_get_ips_to_remove.assert_not_called()
21822182
_remove_from_members_ips.assert_not_called()

0 commit comments

Comments
 (0)