forked from AkkomaGang/akkoma
Merge branch 'fix/2139-oban-migration' into 'develop'
Remove old workers in oban migrations Closes #2139 See merge request pleroma/pleroma!2994
This commit is contained in:
commit
2937e3095a
2 changed files with 4 additions and 0 deletions
|
@ -4,6 +4,8 @@ defmodule Pleroma.Repo.Migrations.MoveActivityExpirationsToOban do
|
||||||
import Ecto.Query, only: [from: 2]
|
import Ecto.Query, only: [from: 2]
|
||||||
|
|
||||||
def change do
|
def change do
|
||||||
|
Pleroma.Config.Oban.warn()
|
||||||
|
|
||||||
Supervisor.start_link([{Oban, Pleroma.Config.get(Oban)}],
|
Supervisor.start_link([{Oban, Pleroma.Config.get(Oban)}],
|
||||||
strategy: :one_for_one,
|
strategy: :one_for_one,
|
||||||
name: Pleroma.Supervisor
|
name: Pleroma.Supervisor
|
||||||
|
|
|
@ -4,6 +4,8 @@ defmodule Pleroma.Repo.Migrations.MoveTokensExpirationIntoOban do
|
||||||
import Ecto.Query, only: [from: 2]
|
import Ecto.Query, only: [from: 2]
|
||||||
|
|
||||||
def change do
|
def change do
|
||||||
|
Pleroma.Config.Oban.warn()
|
||||||
|
|
||||||
Supervisor.start_link([{Oban, Pleroma.Config.get(Oban)}],
|
Supervisor.start_link([{Oban, Pleroma.Config.get(Oban)}],
|
||||||
strategy: :one_for_one,
|
strategy: :one_for_one,
|
||||||
name: Pleroma.Supervisor
|
name: Pleroma.Supervisor
|
||||||
|
|
Loading…
Reference in a new issue