Skip to content

Commit

Permalink
Fix so that the code handles a timeout return
Browse files Browse the repository at this point in the history
(cherry picked from commit dacdeb0)
  • Loading branch information
SimonUnge authored and mergify[bot] committed Oct 24, 2024
1 parent 5530a18 commit b7f324b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ reconciliate_quorum_members(ExpectedNodes, Running, [Q | LocalLeaders],
OldResult) ->
Result =
maybe
{ok, Members, {_, LeaderNode}} = ra:members(amqqueue:get_pid(Q), 500),
{ok, Members, {_, LeaderNode}} ?= ra:members(amqqueue:get_pid(Q), 500),
%% Check if Leader is indeed this node
LeaderNode ?= node(),
%% And that this not is not in maintenance mode
Expand Down

0 comments on commit b7f324b

Please sign in to comment.