Explorar el Código

fix(emqx_alarm): Wait for tables

k32 hace 4 años
padre
commit
0d2d5f6bf9
Se han modificado 1 ficheros con 1 adiciones y 0 borrados
  1. 1 0
      apps/emqx/src/emqx_alarm.erl

+ 1 - 0
apps/emqx/src/emqx_alarm.erl

@@ -180,6 +180,7 @@ to_rfc3339(Timestamp) ->
 %%--------------------------------------------------------------------
 %%--------------------------------------------------------------------
 
 
 init([]) ->
 init([]) ->
+    _ = mria:wait_for_tables([?ACTIVATED_ALARM, ?DEACTIVATED_ALARM]),
     deactivate_all_alarms(),
     deactivate_all_alarms(),
     ok = emqx_config_handler:add_handler([alarm], ?MODULE),
     ok = emqx_config_handler:add_handler([alarm], ?MODULE),
     {ok, #state{timer = ensure_timer(undefined, get_validity_period())}}.
     {ok, #state{timer = ensure_timer(undefined, get_validity_period())}}.