diff --git a/lib/pleroma/workers/worker_helper.ex b/lib/pleroma/workers/worker_helper.ex index 6d27151de..ea9ce9d3b 100644 --- a/lib/pleroma/workers/worker_helper.ex +++ b/lib/pleroma/workers/worker_helper.ex @@ -38,7 +38,7 @@ defmacro __using__(opts) do alias Oban.Job - def enqueue(op, params, worker_args \\ []) do + defp do_enqueue(op, params, worker_args \\ []) do params = Map.merge(%{"op" => op}, params) queue_atom = String.to_atom(unquote(queue)) worker_args = worker_args ++ WorkerHelper.worker_args(queue_atom) @@ -48,11 +48,16 @@ def enqueue(op, params, worker_args \\ []) do |> Oban.insert() end + def enqueue(op, params, worker_args \\ []), + do: do_enqueue(op, params, worker_args) + @impl Oban.Worker def timeout(_job) do queue_atom = String.to_atom(unquote(queue)) Config.get([:workers, :timeout, queue_atom], :timer.minutes(1)) end + + defoverridable enqueue: 3 end end end