diff options
| author | Mark Felder <feld@feld.me> | 2024-07-29 09:59:35 -0400 |
|---|---|---|
| committer | Mark Felder <feld@feld.me> | 2024-07-29 09:59:35 -0400 |
| commit | 8893ad98997197bd89e98f7dd18825dcb1206aa4 (patch) | |
| tree | 97c7cab857030526a180687b0ded8479f3825dd6 /lib | |
| parent | 74072622e08dd1efdc7bf69c3278250ea1efb22e (diff) | |
| download | pleroma-8893ad98997197bd89e98f7dd18825dcb1206aa4.tar.gz pleroma-8893ad98997197bd89e98f7dd18825dcb1206aa4.zip | |
Fix cancelling jobs
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/pleroma/web/common_api.ex | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/pleroma/web/common_api.ex b/lib/pleroma/web/common_api.ex index 06faf845e..b90b6a6d9 100644 --- a/lib/pleroma/web/common_api.ex +++ b/lib/pleroma/web/common_api.ex @@ -714,11 +714,11 @@ defmodule Pleroma.Web.CommonAPI do end end - defp maybe_cancel_jobs(%Activity{data: %{"id" => ap_id}}) do + defp maybe_cancel_jobs(%Activity{id: activity_id}) do Oban.Job |> where([j], j.worker == "Pleroma.Workers.PublisherWorker") |> where([j], j.args["op"] == "publish_one") - |> where([j], j.args["params"]["id"] == ^ap_id) + |> where([j], j.args["params"]["activity_id"] == ^activity_id) |> Oban.cancel_all_jobs() end |