pleroma/priv/repo/migrations/20221103014728_swap_primary_oban_indexes.exs

defmodule Pleroma.Repo.Migrations.SwapPrimaryObanIndexes do
  use Ecto.Migration

  @disable_ddl_transaction true
  @disable_migration_lock true

  def change do
    create_if_not_exists(
      index(
        :oban_jobs,
        [:state, :queue, :priority, :scheduled_at, :id],
        concurrently: true,
        prefix: "public"
      )
    )

    drop_if_exists(
      index(
        :oban_jobs,
        [:queue, :state, :priority, :scheduled_at, :id],
        concurrently: true,
        prefix: "public"
      )
    )
  end
end