diff options
| author | Tusooa Zhu <tusooa@kazv.moe> | 2022-08-06 00:31:36 -0400 |
|---|---|---|
| committer | Tusooa Zhu <tusooa@kazv.moe> | 2022-08-06 00:33:18 -0400 |
| commit | a0166e92fac596651ecaad78659a0f6907ccb6bd (patch) | |
| tree | 07f01b071ddc68248feb608ec1168ff2f9bc6550 /lib | |
| parent | b2ba307f4dc7047ae2b21e2078ba741e2da11cdf (diff) | |
| download | pleroma-a0166e92fac596651ecaad78659a0f6907ccb6bd.tar.gz pleroma-a0166e92fac596651ecaad78659a0f6907ccb6bd.zip | |
Treat MRF rejects as success in Oban worker
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/pleroma/workers/receiver_worker.ex | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/pleroma/workers/receiver_worker.ex b/lib/pleroma/workers/receiver_worker.ex index 268b5f30f..309e197dc 100644 --- a/lib/pleroma/workers/receiver_worker.ex +++ b/lib/pleroma/workers/receiver_worker.ex @@ -9,6 +9,11 @@ defmodule Pleroma.Workers.ReceiverWorker do @impl Oban.Worker def perform(%Job{args: %{"op" => "incoming_ap_doc", "params" => params}}) do - Federator.perform(:incoming_ap_doc, params) + with {:ok, res} <- Federator.perform(:incoming_ap_doc, params) do + {:ok, res} + else + {:error, {:reject, reason}} -> {:cancel, reason} + e -> e + end end end |