summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorMark Felder <feld@feld.me>2024-10-09 16:25:58 -0400
committerMark Felder <feld@feld.me>2024-10-09 16:25:58 -0400
commit03a6e33b81281256f2e9b6ffb75910fdd1a7894f (patch)
tree668052d2222444227b351a0c6db8aabc9e064a21 /lib
parenta3038aa6a2189ced1e5c394a4e6e8be76f2644d0 (diff)
downloadpleroma-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.ex8
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