浏览代码

Merge pull request #13946 from thalesmg/20241007-r58-sf-clear-jwt

fix(snowflake action): delete cached jwt when deleting/stopping action
Thales Macedo Garitezi 1 年之前
父节点
当前提交
bbfadf7027
共有 1 个文件被更改,包括 2 次插入0 次删除
  1. 2 0
      apps/emqx_bridge_snowflake/src/emqx_bridge_snowflake_connector.erl

+ 2 - 0
apps/emqx_bridge_snowflake/src/emqx_bridge_snowflake_connector.erl

@@ -15,6 +15,7 @@
 -include_lib("emqx/include/emqx_trace.hrl").
 -include("emqx_bridge_snowflake.hrl").
 -include_lib("emqx_connector_aggregator/include/emqx_connector_aggregator.hrl").
+-include_lib("emqx_connector_jwt/include/emqx_connector_jwt_tables.hrl").
 
 -elvis([{elvis_style, macro_module_names, disable}]).
 
@@ -798,6 +799,7 @@ destroy_action(ActionResId, ActionState) ->
             ok
     end,
     ok = ehttpc_sup:stop_pool(ActionResId),
+    ok = emqx_connector_jwt:delete_jwt(?JWT_TABLE, ActionResId),
     ok.
 
 run_aggregated_action(Batch, #{aggreg_id := AggregId}) ->