diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl index c3f9728bd..238ce91d3 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl @@ -413,8 +413,8 @@ is_source_alive(Nodes, ResId, _Opts = #{fetch := false}) -> %% get_resource_status -> {ok, #{is_alive => boolean()}} is_source_alive_([]) -> true; is_source_alive_([#{is_alive := true} | ResL]) -> is_source_alive_(ResL); -is_source_alive_([{ok, #{is_alive := true}} | ResL]) -> is_source_alive_(ResL); is_source_alive_([#{is_alive := false} | _ResL]) -> false; +is_source_alive_([{ok, #{is_alive := true}} | ResL]) -> is_source_alive_(ResL); is_source_alive_([{ok, #{is_alive := false}} | _ResL]) -> false; is_source_alive_([_Error | _ResL]) -> false.