diff options
| author | Mark Felder <feld@feld.me> | 2024-07-30 11:48:10 -0400 |
|---|---|---|
| committer | Mark Felder <feld@feld.me> | 2024-07-30 11:48:10 -0400 |
| commit | b50261262ebc90739b8868ca588d3a8d6ed43b7d (patch) | |
| tree | 950fdc47602eeb85d724c9e987b07379c501d603 | |
| parent | 355b028c23bf977ff2006d384d2a66d2a9dfa28b (diff) | |
| download | pleroma-b50261262ebc90739b8868ca588d3a8d6ed43b7d.tar.gz pleroma-b50261262ebc90739b8868ca588d3a8d6ed43b7d.zip | |
Fix publisher job migration error
| -rw-r--r-- | changelog.d/fix-migration.skip | 0 | ||||
| -rw-r--r-- | priv/repo/migrations/20240729163838_publisher_job_change.exs | 13 |
2 files changed, 9 insertions, 4 deletions
diff --git a/changelog.d/fix-migration.skip b/changelog.d/fix-migration.skip new file mode 100644 index 000000000..e69de29bb --- /dev/null +++ b/changelog.d/fix-migration.skip diff --git a/priv/repo/migrations/20240729163838_publisher_job_change.exs b/priv/repo/migrations/20240729163838_publisher_job_change.exs index 3449e3b3b..cbea18205 100644 --- a/priv/repo/migrations/20240729163838_publisher_job_change.exs +++ b/priv/repo/migrations/20240729163838_publisher_job_change.exs @@ -16,12 +16,17 @@ defmodule Pleroma.Repo.Migrations.PublisherJobChange do Enum.each(jobs, fn job -> args = job.args - activity = Activity.get_by_ap_id(args["id"]) - updated_args = Map.put(args, "activity_id", activity.id) + case Activity.get_by_ap_id(args["id"]) do + nil -> + :ok - Pleroma.Workers.PublisherWorker.new(updated_args) - |> Oban.insert() + %Activity{id: activity_id} -> + updated_args = Map.put(args, "activity_id", activity_id) + + Pleroma.Workers.PublisherWorker.new(updated_args) + |> Oban.insert() + end end) end end |