Git of dcc - anni/blob - priv/repo/migrations/20200911055909_remove_cron_jobs.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Repo.Migrations.RemoveCronJobs do
   6   use Ecto.Migration
   7
   8   import Ecto.Query, only: [from: 2]
   9
  10   def up do
  11     from(j in "oban_jobs",
  12       where:
  13         j.worker in ^[
  14           "Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker",
  15           "Pleroma.Workers.Cron.StatsWorker",
  16           "Pleroma.Workers.Cron.ClearOauthTokenWorker"
  17         ],
  18       select: [:id]
  19     )
  20     |> Pleroma.Repo.delete_all()
  21   end
  22
  23   def down, do: :ok
  24 end