chore(rebalance): fix flaky test

This commit is contained in:
Ilya Averyanov 2023-08-08 13:06:25 +03:00
parent 5b4d09560b
commit 9245162394
1 changed files with 6 additions and 5 deletions

View File

@ -278,13 +278,14 @@ t_session_serialization(_Config) ->
emqx_eviction_agent:session_count()
),
[ChanPid0] = emqx_cm:lookup_channels(<<"client_with_session">>),
MRef0 = erlang:monitor(process, ChanPid0),
%% Evacuate to the same node
?assertWaitEvent(
emqx_eviction_agent:evict_sessions(1, node()),
#{?snk_kind := emqx_channel_takeover_end, clientid := <<"client_with_session">>},
1000
),
_ = emqx_eviction_agent:evict_sessions(1, node()),
?assertReceive({'DOWN', MRef0, process, ChanPid0, _}),
ok = emqx_eviction_agent:disable(test_eviction),