diff options
author | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-09-06 12:13:26 +0300 |
---|---|---|
committer | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-09-07 19:16:14 +0300 |
commit | ee67c98e550310813cfdb9242e5fab2e566e1e2a (patch) | |
tree | 4a1682f111cfe3378d91685111f7ae9d15013d71 /priv | |
parent | 6c6de8e5dfaf245e4e16ddca0c741342eeaa9187 (diff) |
removing Stats worker from Oban cron jobs
Diffstat (limited to 'priv')
-rw-r--r-- | priv/repo/migrations/20200906072147_remove_cron_stats_worker_from_oban_config.exs | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/priv/repo/migrations/20200906072147_remove_cron_stats_worker_from_oban_config.exs b/priv/repo/migrations/20200906072147_remove_cron_stats_worker_from_oban_config.exs new file mode 100644 index 000000000..022f21dc7 --- /dev/null +++ b/priv/repo/migrations/20200906072147_remove_cron_stats_worker_from_oban_config.exs @@ -0,0 +1,19 @@ +defmodule Pleroma.Repo.Migrations.RemoveCronStatsWorkerFromObanConfig do + use Ecto.Migration + + def change do + with %Pleroma.ConfigDB{} = config <- + Pleroma.ConfigDB.get_by_params(%{group: :pleroma, key: Oban}), + crontab when is_list(crontab) <- config.value[:crontab], + index when is_integer(index) <- + Enum.find_index(crontab, fn {_, worker} -> + worker == Pleroma.Workers.Cron.StatsWorker + end) do + updated_value = Keyword.put(config.value, :crontab, List.delete_at(crontab, index)) + + config + |> Ecto.Changeset.change(value: updated_value) + |> Pleroma.Repo.update() + end + end +end |