diff options
| author | Mark Felder <feld@feld.me> | 2024-07-30 10:48:06 -0400 |
|---|---|---|
| committer | Mark Felder <feld@feld.me> | 2024-07-30 10:58:10 -0400 |
| commit | 1bce582f0de896b2a84cc2ef44f82646276dc255 (patch) | |
| tree | 14312ba93a919699167f6f0a127a4fbfbbe9dd40 | |
| parent | 05d4989795b79683933aa602cd427c57ded10e2f (diff) | |
| download | pleroma-1bce582f0de896b2a84cc2ef44f82646276dc255.tar.gz pleroma-1bce582f0de896b2a84cc2ef44f82646276dc255.zip | |
Fix migration crashing due to Oban not running
We can use Pleroma.Repo to fetch the jobs
| -rw-r--r-- | priv/repo/migrations/20240729163838_publisher_job_change.exs | 4 |
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 |