Просмотр исходного кода

test: relax recoverable/unrecoverable error check

for now, treat all other errors unrecoverable
Zaiming (Stone) Shi 3 лет назад
Родитель
Сommit
faf5916ed6
1 измененных файлов с 7 добавлено и 0 удалено
  1. 7 0
      apps/emqx_resource/src/emqx_resource_worker.erl

+ 7 - 0
apps/emqx_resource/src/emqx_resource_worker.erl

@@ -1222,8 +1222,15 @@ mark_as_sent(?QUERY(From, Req, _)) ->
 
 is_unrecoverable_error({error, {unrecoverable_error, _}}) ->
     true;
+is_unrecoverable_error({error, {recoverable_error, _}}) ->
+    false;
 is_unrecoverable_error({async_return, Result}) ->
     is_unrecoverable_error(Result);
+is_unrecoverable_error({error, _}) ->
+    %% TODO: delete this clause.
+    %% Ideally all errors except for 'unrecoverable_error' should be
+    %% retried, including DB schema errors.
+    true;
 is_unrecoverable_error(_) ->
     false.