m/akkoma
1
0
Fork 0
forked from AkkomaGang/akkoma
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix Cron.PurgeExpiredActivitiesWorker

Browse source
This commit is contained in:
Maksim Pechnikov 2020-08-13 21:01:21 +03:00
parent 14a06e63f6
commit 3515cb5c3a
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
lib/pleroma/workers/cron/purge_expired_activities_worker.ex
View file

@ -21,11 +21,12 @@ defmodule Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker do
@impl Oban.Worker @impl Oban.Worker
def perform(_job) do def perform(_job) do
if Config.get([ActivityExpiration, :enabled]) do if Config.get([ActivityExpiration, :enabled]) do
Enum.each(ActivityExpiration.due_expirations(@interval), &delete_activity/1) Enum.each(ActivityExpiration.due_expirations(@interval), &delete_activity/1)
else end
:ok
end after
:ok
end end
def delete_activity(%ActivityExpiration{activity_id: activity_id}) do def delete_activity(%ActivityExpiration{activity_id: activity_id}) do
@ -41,7 +42,7 @@ def delete_activity(%ActivityExpiration{activity_id: activity_id}) do
{:user, _} -> {:user, _} ->
Logger.error( Logger.error(
"#{__MODULE__} Couldn't delete expired activity: not found actorof ##{activity_id}" "#{__MODULE__} Couldn't delete expired activity: not found actor of ##{activity_id}"
) )
end end
end end