root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 6 Packages Projects Releases Wiki Activity

introduce rabbit_ct_helpers:await_condition_* helpers which ignore exceptions

This commit is contained in:
Ayanda Dube 2025-07-22 16:26:51 +01:00
parent 36fd79cd9e
commit c35533d675
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
deps/rabbitmq_ct_helpers/src/rabbit_ct_helpers.erl vendored
View File

@ -55,6 +55,10 @@
await_condition/2,
await_condition_with_retries/2,
await_condition_ignoring_exceptions/1,
await_condition_ignoring_exceptions/2,
await_condition_with_retries_ignoring_exceptions/2,
eventually/1, eventually/3,
consistently/1, consistently/3,
@ -1138,6 +1142,28 @@ await_condition_with_retries(ConditionFun, RetriesLeft) ->
ok
end.
await_condition_ignoring_exceptions(ConditionFun) ->
await_condition_ignoring_exceptions(ConditionFun, 10_000).
await_condition_ignoring_exceptions(ConditionFun, Timeout) ->
Retries = ceil(Timeout / 50),
await_condition_with_retries_ignoring_exceptions(ConditionFun, Retries).
await_condition_with_retries_ignoring_exceptions(_ConditionFun, 0) ->
ct:fail("Condition did not materialize in the expected period of time");
await_condition_with_retries_ignoring_exceptions(ConditionFun, RetriesLeft) ->
try ConditionFun() of
false ->
timer:sleep(50),
await_condition_with_retries_ignoring_exceptions(ConditionFun, RetriesLeft - 1);
true ->
ok
catch
_:_ ->
timer:sleep(50),
await_condition_with_retries_ignoring_exceptions(ConditionFun, RetriesLeft - 1)
end.
%% Pass in any EUnit test object. Example:
%% eventually(?_assertEqual(1, Actual))
eventually({Line, Assertion} = TestObj)