From 72579f90142f09a463c57372f2d11ca5892403b7 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Wed, 3 Jul 2024 15:05:00 -0300 Subject: [PATCH] test(postgres bridge): attempt to stabilize flaky test ``` %%% emqx_bridge_pgsql_SUITE ==> tcp.sync.with_batch.t_table_removed: FAILED %%% emqx_bridge_pgsql_SUITE ==> {{panic, #{msg => "Unexpected result", result => {run_stage_failed,exit, {test_case_failed, "unexpected result: {error,{recoverable_error,sync_required}}"}, [{emqx_bridge_pgsql_SUITE,'-t_table_removed/1-fun-3-',3, [{file, "/emqx/apps/emqx_bridge_pgsql/test/emqx_bridge_pgsql_SUITE.erl"}, {line,822}]}, ``` ``` Error: -03T17:52:54.046809+00:00 [error] Generic server <0.352770.0> terminating. Reason: {'module could not be loaded',[{undefined,handle_message,[90,<<"I">>,{state,ssl,{sslsocket,{gen_tcp,#Port<0.1671>,tls_connection,undefined},[<0.352774.0>,<0.352773.0>]},<<>>,{336,-2093820527},on_message,{codec,#{},[null,undefined],{oid_db,#{16 => ... 2024-07-03T17:52:54.075446+00:00 [critical] Run stage failed: exit:{test_case_failed,"unexpected result: {error,\n {resource_error,\n #{reason => exception,\n msg =>\n #{error =>\n {exit,\n {{undef,\n [{undefined,handle_message,\n [90,<<\"I\">>,\n {state,ssl,\n {sslsocket,\n {gen_tcp,#Port<0.1671>,tls_connection,\n ``` --- apps/emqx_bridge_pgsql/test/emqx_bridge_pgsql_SUITE.erl | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/emqx_bridge_pgsql/test/emqx_bridge_pgsql_SUITE.erl b/apps/emqx_bridge_pgsql/test/emqx_bridge_pgsql_SUITE.erl index f671c90df..a88cddf76 100644 --- a/apps/emqx_bridge_pgsql/test/emqx_bridge_pgsql_SUITE.erl +++ b/apps/emqx_bridge_pgsql/test/emqx_bridge_pgsql_SUITE.erl @@ -728,8 +728,8 @@ t_prepared_statement_exists(Config) -> emqx_common_test_helpers:on_exit(fun() -> meck:unload() end), - MeckOpts = [passthrough, no_link, no_history, non_strict], - meck:new(emqx_postgresql, MeckOpts), + MeckOpts = [passthrough, no_link, no_history], + meck:new(epgsql, MeckOpts), InsertPrepStatementDupAndThenRemoveMeck = fun(Conn, Key, SQL, List) -> meck:passthrough([Conn, Key, SQL, List]), @@ -795,6 +795,7 @@ t_prepared_statement_exists(Config) -> ok end ), + meck:unload(), ok. t_table_removed(Config) ->