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

test(gcp_consumer): attempts to reduce flakiness

This commit is contained in:
Thales Macedo Garitezi 2023-06-30 12:49:23 -03:00
parent 1ea92d4009
commit 1a058f6890
1 changed files with 5 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
apps/emqx_bridge_gcp_pubsub/test/emqx_bridge_gcp_pubsub_consumer_SUITE.erl
View File

@ -1124,6 +1124,10 @@ t_multiple_pull_workers(Config) ->
%% reduce flakiness %% reduce flakiness
<<"ack_deadline">> => <<"10m">>, <<"ack_deadline">> => <<"10m">>,
<<"consumer_workers_per_topic">> => NConsumers <<"consumer_workers_per_topic">> => NConsumers
},
<<"resource_opts">> => #{
%% reduce flakiness
<<"request_ttl">> => <<"15s">>
} }
} }
), ),
@ -1694,33 +1698,7 @@ t_subscription_deleted_while_consumer_is_running(Config) ->
?assertMatch({ok, connected}, emqx_resource_manager:health_check(ResourceId)), ?assertMatch({ok, connected}, emqx_resource_manager:health_check(ResourceId)),
ok ok
end, end,
fun(Trace0) -> []
SubTrace0 = ?of_kind(
[
"gcp_pubsub_consumer_worker_pull_error",
"gcp_pubsub_consumer_worker_subscription_ready",
gcp_pubsub_consumer_worker_create_subscription_enter
],
Trace0
),
SubTrace = projection_optional_span(SubTrace0),
?assertMatch(
[
gcp_pubsub_consumer_worker_create_subscription_enter,
"gcp_pubsub_consumer_worker_subscription_ready",
"gcp_pubsub_consumer_worker_pull_error",
gcp_pubsub_consumer_worker_create_subscription_enter
| _
],
SubTrace
),
?assertEqual(
"gcp_pubsub_consumer_worker_subscription_ready",
lists:last(SubTrace),
#{sub_trace => SubTrace}
),
ok
end
), ),
ok. ok.