logo

pleroma

My custom branche(s) on git.pleroma.social/pleroma/pleroma git clone https://hacktivis.me/git/pleroma.git
commit: 10528344c7c56c70dcfc09a72ff5f109f7b952fe
parent 74179e6ac365dbbfbc08590a03def4b5a69b22e6
Author: Alexander Strizhakov <alex.strizhakov@gmail.com>
Date:   Fri, 13 Nov 2020 09:07:08 +0300

remove PurgeExpiredActivity from Oban db config

Diffstat:

Apriv/repo/migrations/20201113060459_remove_purge_expired_activity_worker_from_oban_config.exs19+++++++++++++++++++
1 file changed, 19 insertions(+), 0 deletions(-)

diff --git a/priv/repo/migrations/20201113060459_remove_purge_expired_activity_worker_from_oban_config.exs b/priv/repo/migrations/20201113060459_remove_purge_expired_activity_worker_from_oban_config.exs @@ -0,0 +1,19 @@ +defmodule Pleroma.Repo.Migrations.RemovePurgeExpiredActivityWorkerFromObanConfig 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.PurgeExpiredActivitiesWorker + 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