yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #13590 from thalesmg/20240807-r58-test-flaky-serde 

test: reduce inter-case flakiness
This commit is contained in:
Thales Macedo Garitezi 2024-08-08 08:56:33 -03:00 committed by GitHub
parent 6849801293 6c4cfeed92
commit 7711307909
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apps/emqx_schema_registry/src/emqx_schema_registry.erl
View File

@ -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

10
apps/emqx_schema_registry/test/emqx_schema_registry_serde_SUITE.erl
View File

@ -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()
). ).