diff options
author | rinpatch <rinpatch@sdf.org> | 2020-03-07 09:32:29 +0000 |
---|---|---|
committer | rinpatch <rinpatch@sdf.org> | 2020-03-07 09:32:29 +0000 |
commit | 6d797b99282ff1067c6af04b3e1775ff2281333b (patch) | |
tree | 1cbf5a46c9f139e0b9ebbe2e1e9a0a5386681af2 /lib | |
parent | 46f118d7e1d570fa4f4d1235f9c38c6040f814fb (diff) | |
parent | 400fbc7629ff0fbf931cd5cc84d8ce170cd38e1d (diff) | |
download | pleroma-6d797b99282ff1067c6af04b3e1775ff2281333b.tar.gz |
Merge branch 'restart-fix-for-mix-tasks' into 'develop'
Wait in mix task while pleroma is rebooted
See merge request pleroma/pleroma!2225
Diffstat (limited to 'lib')
-rw-r--r-- | lib/mix/pleroma.ex | 13 | ||||
-rw-r--r-- | lib/pleroma/config/transfer_task.ex | 6 |
2 files changed, 18 insertions, 1 deletions
diff --git a/lib/mix/pleroma.ex b/lib/mix/pleroma.ex index 90f8c8008..3ad6edbfb 100644 --- a/lib/mix/pleroma.ex +++ b/lib/mix/pleroma.ex @@ -12,6 +12,19 @@ defmodule Mix.Pleroma do end {:ok, _} = Application.ensure_all_started(:pleroma) + + if Pleroma.Config.get(:env) not in [:test, :benchmark] do + pleroma_rebooted?() + end + end + + defp pleroma_rebooted? do + if Restarter.Pleroma.rebooted?() do + :ok + else + Process.sleep(10) + pleroma_rebooted?() + end end def load_pleroma do diff --git a/lib/pleroma/config/transfer_task.ex b/lib/pleroma/config/transfer_task.ex index 1846aa22c..435fc7450 100644 --- a/lib/pleroma/config/transfer_task.ex +++ b/lib/pleroma/config/transfer_task.ex @@ -42,7 +42,8 @@ defmodule Pleroma.Config.TransferTask do @spec load_and_update_env([ConfigDB.t()]) :: :ok | false def load_and_update_env(deleted \\ [], restart_pleroma? \\ true) do - with true <- Pleroma.Config.get(:configurable_from_database), + with {:configurable, true} <- + {:configurable, Pleroma.Config.get(:configurable_from_database)}, true <- Ecto.Adapters.SQL.table_exists?(Repo, "config"), started_applications <- Application.started_applications() do # We need to restart applications for loaded settings take effect @@ -65,12 +66,15 @@ defmodule Pleroma.Config.TransferTask do if :pleroma in applications do List.delete(applications, :pleroma) ++ [:pleroma] else + Restarter.Pleroma.rebooted() applications end Enum.each(applications, &restart(started_applications, &1, Pleroma.Config.get(:env))) :ok + else + {:configurable, false} -> Restarter.Pleroma.rebooted() end end |