summaryrefslogtreecommitdiff
path: root/priv/repo/migrations/20240729163838_publisher_job_change.exs
diff options
context:
space:
mode:
Diffstat (limited to 'priv/repo/migrations/20240729163838_publisher_job_change.exs')
-rw-r--r--priv/repo/migrations/20240729163838_publisher_job_change.exs4
1 files changed, 2 insertions, 2 deletions
diff --git a/priv/repo/migrations/20240729163838_publisher_job_change.exs b/priv/repo/migrations/20240729163838_publisher_job_change.exs
index 08d73b5ad..3449e3b3b 100644
--- a/priv/repo/migrations/20240729163838_publisher_job_change.exs
+++ b/priv/repo/migrations/20240729163838_publisher_job_change.exs
@@ -2,6 +2,7 @@ defmodule Pleroma.Repo.Migrations.PublisherJobChange do
use Ecto.Migration
alias Pleroma.Activity
+ alias Pleroma.Repo
import Ecto.Query
def up do
@@ -11,8 +12,7 @@ defmodule Pleroma.Repo.Migrations.PublisherJobChange do
where: j.state in ["available", "retryable"]
)
- jobs =
- Oban |> Oban.config() |> Oban.Repo.all(query)
+ jobs = Repo.all(query)
Enum.each(jobs, fn job ->
args = job.args