From b5aaef084c2225d3ccf8f93cc9ce09288015cda0 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Mon, 16 Jan 2023 18:09:05 -0300 Subject: [PATCH] refactor: enter running state directly now that we don't have the possibility of dirty disk queues (we always use volatile replayq), we will never resume old work. --- apps/emqx_resource/src/emqx_resource_worker.erl | 2 +- apps/emqx_resource/test/emqx_resource_SUITE.erl | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqx_resource/src/emqx_resource_worker.erl b/apps/emqx_resource/src/emqx_resource_worker.erl index ca8e244ae..59fd41a03 100644 --- a/apps/emqx_resource/src/emqx_resource_worker.erl +++ b/apps/emqx_resource/src/emqx_resource_worker.erl @@ -189,7 +189,7 @@ init({Id, Index, Opts}) -> tref => undefined }, ?tp(resource_worker_init, #{id => Id, index => Index}), - {ok, blocked, Data, {next_event, cast, resume}}. + {ok, running, Data}. running(enter, _, St) -> ?tp(resource_worker_enter_running, #{}), diff --git a/apps/emqx_resource/test/emqx_resource_SUITE.erl b/apps/emqx_resource/test/emqx_resource_SUITE.erl index 4ffb259e8..da140489e 100644 --- a/apps/emqx_resource/test/emqx_resource_SUITE.erl +++ b/apps/emqx_resource/test/emqx_resource_SUITE.erl @@ -1200,7 +1200,7 @@ t_delete_and_re_create_with_same_name(_Config) -> resume_interval => 1_000 } ), - #{?snk_kind := resource_worker_enter_blocked}, + #{?snk_kind := resource_worker_enter_running}, 5_000 ),