yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(emqx_rule_runtime): Dialyzer warnings

This commit is contained in:
Zaiming Shi 2020-11-09 21:59:59 +01:00
parent 764d5977c1
commit 42ed274ec3
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_rule_engine/src/emqx_rule_runtime.erl
View File

@ -291,11 +291,11 @@ wait_action_on(Id, RetryN) ->
handle_action_failure(continue, Id, Fallbacks, Selected, Envs, Reason) -> handle_action_failure(continue, Id, Fallbacks, Selected, Envs, Reason) ->
?LOG(error, "Take action ~p failed, continue next action, reason: ~0p", [Id, Reason]), ?LOG(error, "Take action ~p failed, continue next action, reason: ~0p", [Id, Reason]),
take_actions(Fallbacks, Selected, Envs, continue), _ = take_actions(Fallbacks, Selected, Envs, continue),
failed; failed;
handle_action_failure(stop, Id, Fallbacks, Selected, Envs, Reason) -> handle_action_failure(stop, Id, Fallbacks, Selected, Envs, Reason) ->
?LOG(error, "Take action ~p failed, skip all actions, reason: ~0p", [Id, Reason]), ?LOG(error, "Take action ~p failed, skip all actions, reason: ~0p", [Id, Reason]),
take_actions(Fallbacks, Selected, Envs, continue), _ = take_actions(Fallbacks, Selected, Envs, continue),
error({take_action_failed, {Id, Reason}}). error({take_action_failed, {Id, Reason}}).
eval({path, [{key, <<"payload">>} | Path]}, #{payload := Payload}) -> eval({path, [{key, <<"payload">>} | Path]}, #{payload := Payload}) ->