diff --git a/apps/emqx_connector/src/emqx_connector_resource.erl b/apps/emqx_connector/src/emqx_connector_resource.erl index 8cb61793d..cdbba4f95 100644 --- a/apps/emqx_connector/src/emqx_connector_resource.erl +++ b/apps/emqx_connector/src/emqx_connector_resource.erl @@ -125,6 +125,7 @@ create(Type, Name, Conf0, Opts) -> TypeBin = bin(Type), ResourceId = resource_id(Type, Name), Conf = Conf0#{connector_type => TypeBin, connector_name => Name}, + _ = emqx_alarm:ensure_deactivated(ResourceId), {ok, _Data} = emqx_resource:create_local( ResourceId, ?CONNECTOR_RESOURCE_GROUP, @@ -132,7 +133,6 @@ create(Type, Name, Conf0, Opts) -> parse_confs(TypeBin, Name, Conf), parse_opts(Conf, Opts) ), - _ = emqx_alarm:ensure_deactivated(ResourceId), ok. update(ConnectorId, {OldConf, Conf}) ->