forked from AkkomaGang/akkoma
TEMP: add logging for cleanup worker
This commit is contained in:
parent
d6592053e9
commit
d89d189bd3
1 changed files with 4 additions and 0 deletions
|
@ -10,6 +10,8 @@ defmodule Pleroma.Workers.AttachmentsCleanupWorker do
|
||||||
|
|
||||||
use Pleroma.Workers.WorkerHelper, queue: "attachments_cleanup"
|
use Pleroma.Workers.WorkerHelper, queue: "attachments_cleanup"
|
||||||
|
|
||||||
|
require Logger
|
||||||
|
|
||||||
@impl Oban.Worker
|
@impl Oban.Worker
|
||||||
def perform(%Job{
|
def perform(%Job{
|
||||||
args: %{
|
args: %{
|
||||||
|
@ -18,6 +20,8 @@ defmodule Pleroma.Workers.AttachmentsCleanupWorker do
|
||||||
}
|
}
|
||||||
}) do
|
}) do
|
||||||
if Pleroma.Config.get([:instance, :cleanup_attachments], false) do
|
if Pleroma.Config.get([:instance, :cleanup_attachments], false) do
|
||||||
|
Logger.notice("EASY_TO_GREP_ACW: Trying to cleanup #{inspect(hrefs)}")
|
||||||
|
|
||||||
attachments
|
attachments
|
||||||
|> Enum.flat_map(fn item -> Enum.map(item["url"], & &1["href"]) end)
|
|> Enum.flat_map(fn item -> Enum.map(item["url"], & &1["href"]) end)
|
||||||
|> fetch_objects
|
|> fetch_objects
|
||||||
|
|
Loading…
Reference in a new issue