test: reduce inter-case flakiness
This commit is contained in:
parent
81978ceaeb
commit
6c4cfeed92
|
@ -339,6 +339,7 @@ ensure_serde_absent(Name) ->
|
||||||
{ok, Serde} ->
|
{ok, Serde} ->
|
||||||
ok = emqx_schema_registry_serde:destroy(Serde),
|
ok = emqx_schema_registry_serde:destroy(Serde),
|
||||||
_ = ets:delete(?SERDE_TAB, Name),
|
_ = ets:delete(?SERDE_TAB, Name),
|
||||||
|
?tp("schema_registry_serde_deleted", #{name => Name}),
|
||||||
ok;
|
ok;
|
||||||
{error, not_found} ->
|
{error, not_found} ->
|
||||||
ok
|
ok
|
||||||
|
|
|
@ -57,7 +57,15 @@ end_per_testcase(_TestCase, _Config) ->
|
||||||
clear_schemas() ->
|
clear_schemas() ->
|
||||||
maps:foreach(
|
maps:foreach(
|
||||||
fun(Name, _Schema) ->
|
fun(Name, _Schema) ->
|
||||||
ok = emqx_schema_registry:delete_schema(Name)
|
NameBin = emqx_utils_conv:bin(Name),
|
||||||
|
{ok, {ok, _}} =
|
||||||
|
?wait_async_action(
|
||||||
|
emqx_schema_registry:delete_schema(Name),
|
||||||
|
#{
|
||||||
|
?snk_kind := "schema_registry_serde_deleted",
|
||||||
|
name := NameBin
|
||||||
|
}
|
||||||
|
)
|
||||||
end,
|
end,
|
||||||
emqx_schema_registry:list_schemas()
|
emqx_schema_registry:list_schemas()
|
||||||
).
|
).
|
||||||
|
|
Loading…
Reference in New Issue