diff options
| author | Ivan Tashkinov <ivantashkinov@gmail.com> | 2019-08-31 21:58:42 +0300 |
|---|---|---|
| committer | Ivan Tashkinov <ivantashkinov@gmail.com> | 2019-08-31 21:58:42 +0300 |
| commit | dd017c65a4b86501c435f5cb01804300e6b7c6dd (patch) | |
| tree | 974377c7e52c8960251881cb939632ea8288dbb6 /lib/pleroma/web/oauth/token/clean_worker.ex | |
| parent | a90ea8ba1562818b025f677ffeea35f7ca08ddf2 (diff) | |
| download | pleroma-dd017c65a4b86501c435f5cb01804300e6b7c6dd.tar.gz | |
[#1149] Refactored Oban workers API (introduced `enqueue/3`).
Diffstat (limited to 'lib/pleroma/web/oauth/token/clean_worker.ex')
| -rw-r--r-- | lib/pleroma/web/oauth/token/clean_worker.ex | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/lib/pleroma/web/oauth/token/clean_worker.ex b/lib/pleroma/web/oauth/token/clean_worker.ex index b150a68a7..eb94bf86f 100644 --- a/lib/pleroma/web/oauth/token/clean_worker.ex +++ b/lib/pleroma/web/oauth/token/clean_worker.ex @@ -16,12 +16,9 @@ defmodule Pleroma.Web.OAuth.Token.CleanWorker do @one_day ) - alias Pleroma.Repo alias Pleroma.Web.OAuth.Token alias Pleroma.Workers.BackgroundWorker - import Pleroma.Workers.WorkerHelper, only: [worker_args: 1] - def start_link(_), do: GenServer.start_link(__MODULE__, %{}) def init(_) do @@ -31,9 +28,7 @@ defmodule Pleroma.Web.OAuth.Token.CleanWorker do @doc false def handle_info(:perform, state) do - %{"op" => "clean_expired_tokens"} - |> BackgroundWorker.new(worker_args(:background)) - |> Repo.insert() + BackgroundWorker.enqueue("clean_expired_tokens", %{}) Process.send_after(self(), :perform, @interval) {:noreply, state} |