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
                 ),