diff options
| author | Haelwenn <contact+git.pleroma.social@hacktivis.me> | 2020-09-11 08:58:01 +0000 |
|---|---|---|
| committer | Haelwenn <contact+git.pleroma.social@hacktivis.me> | 2020-09-11 08:58:01 +0000 |
| commit | 03d1730f30787c10e7e12894eef8e945b6e9d670 (patch) | |
| tree | f9f62806eda5ec6a7f9221b5d7fcde6d6ff417d4 | |
| parent | 6316350918d1f55167fa384d55f385ff2c93e6bb (diff) | |
| parent | e3ca0a7e2d18ca9b3c809282678456d4517d39bc (diff) | |
Merge branch 'fix/2134-old-cron-jobs' into 'develop'
Migration to remove old cron jobs
Closes #2134
See merge request pleroma/pleroma!2987
| -rw-r--r-- | priv/repo/migrations/20200911055909_remove_cron_jobs.exs | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/priv/repo/migrations/20200911055909_remove_cron_jobs.exs b/priv/repo/migrations/20200911055909_remove_cron_jobs.exs new file mode 100644 index 000000000..33897d128 --- /dev/null +++ b/priv/repo/migrations/20200911055909_remove_cron_jobs.exs @@ -0,0 +1,20 @@ +defmodule Pleroma.Repo.Migrations.RemoveCronJobs do + use Ecto.Migration + + import Ecto.Query, only: [from: 2] + + def up do + from(j in "oban_jobs", + where: + j.worker in ^[ + "Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker", + "Pleroma.Workers.Cron.StatsWorker", + "Pleroma.Workers.Cron.ClearOauthTokenWorker" + ], + select: [:id] + ) + |> Pleroma.Repo.delete_all() + end + + def down, do: :ok +end |