fix(resource): make sure resource will not crash when stopping

2023-04-23 15:31:08 +08:00 · 2023-04-23 15:31:08 +08:00 · 7d2c336ab7
parent 6ef032026f
commit 7d2c336ab7
1 changed files with 1 additions and 5 deletions
--- a/apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl
+++ b/apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl
@ -141,9 +141,5 @@ ensure_disk_queue_dir_absent(ResourceId, Index) ->
    ok.

 ensure_worker_pool_removed(ResId) ->
-    try
-        gproc_pool:delete(ResId)
-    catch
-        error:badarg -> ok
-    end,
+    gproc_pool:force_delete(ResId),
    ok.