summaryrefslogtreecommitdiff
path: root/priv
diff options
context:
space:
mode:
authorrinpatch <rinpatch@sdf.org>2020-09-07 16:49:27 +0000
committerrinpatch <rinpatch@sdf.org>2020-09-07 16:49:27 +0000
commitc5434dbefc5e6a25ffb72debe8ed9e09d77bf885 (patch)
tree11980801b18ed17ae5ea31fedb311177454be8bc /priv
parent6c6de8e5dfaf245e4e16ddca0c741342eeaa9187 (diff)
parent8c6485c470c1a7cd6ec4b63867d94e9724c4502b (diff)
downloadpleroma-c5434dbefc5e6a25ffb72debe8ed9e09d77bf885.tar.gz
pleroma-c5434dbefc5e6a25ffb72debe8ed9e09d77bf885.zip
Merge branch 'feature/1790-oban-overuse' into 'develop'
removing StatsWorker from Oban cron jobs See merge request pleroma/pleroma!2963
Diffstat (limited to 'priv')
-rw-r--r--priv/repo/migrations/20200906072147_remove_cron_stats_worker_from_oban_config.exs19
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