Worker which purges expired filters
"""
- use Oban.Worker, queue: :filter_expiration, max_attempts: 1, unique: [fields: [:args]]
+ use Oban.Worker, queue: :filter_expiration, max_attempts: 1, unique: [period: :infinity]
import Ecto.Query
|> Oban.insert()
end
+ @impl Oban.Worker
+ def timeout(_job) do
+ Pleroma.Config.get([:workers, :timeout, :filter_expiration], :timer.minutes(1))
+ end
+
@impl true
def perform(%Job{args: %{"filter_id" => id}}) do
Pleroma.Filter