diff options
author | Mark Felder <feld@feld.me> | 2024-10-09 16:25:58 -0400 |
---|---|---|
committer | Mark Felder <feld@feld.me> | 2024-10-09 16:25:58 -0400 |
commit | 03a6e33b81281256f2e9b6ffb75910fdd1a7894f (patch) | |
tree | 668052d2222444227b351a0c6db8aabc9e064a21 /lib | |
parent | a3038aa6a2189ced1e5c394a4e6e8be76f2644d0 (diff) | |
download | pleroma-03a6e33b81281256f2e9b6ffb75910fdd1a7894f.tar.gz pleroma-03a6e33b81281256f2e9b6ffb75910fdd1a7894f.zip |
Skip the final refresh job if the activity is local
Diffstat (limited to 'lib')
-rw-r--r-- | lib/pleroma/workers/poll_worker.ex | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/lib/pleroma/workers/poll_worker.ex b/lib/pleroma/workers/poll_worker.ex index 7d69bea54..a9afe9d63 100644 --- a/lib/pleroma/workers/poll_worker.ex +++ b/lib/pleroma/workers/poll_worker.ex @@ -22,9 +22,11 @@ defmodule Pleroma.Workers.PollWorker do def perform(%Job{args: %{"op" => "poll_end", "activity_id" => activity_id}}) do with {_, %Activity{} = activity} <- {:activity, Activity.get_by_id(activity_id)}, {:ok, notifications} <- Notification.create_poll_notifications(activity) do - # Schedule a final refresh - __MODULE__.new(%{"op" => "refresh", "activity_id" => activity_id}) - |> Oban.insert() + unless activity.local do + # Schedule a final refresh + __MODULE__.new(%{"op" => "refresh", "activity_id" => activity_id}) + |> Oban.insert() + end Notification.stream(notifications) else |