diff --git a/config/config.exs b/config/config.exs index 805cd0d62..372852a7b 100644 --- a/config/config.exs +++ b/config/config.exs @@ -603,8 +603,7 @@ config :pleroma, Oban, crontab: [ {"0 0 * * 0", Pleroma.Workers.Cron.DigestEmailsWorker}, {"0 0 * * *", Pleroma.Workers.Cron.NewUsersDigestWorker}, - {"*/10 * * * *", Pleroma.Workers.Cron.AppCleanupWorker}, - {"0 0 * * *", Pleroma.Workers.Cron.ScheduleReachabilityWorker} + {"*/10 * * * *", Pleroma.Workers.Cron.AppCleanupWorker} ] config :pleroma, Pleroma.Formatter, diff --git a/lib/pleroma/workers/cron/schedule_reachability_worker.ex b/lib/pleroma/workers/cron/schedule_reachability_worker.ex deleted file mode 100644 index a0b8e261c..000000000 --- a/lib/pleroma/workers/cron/schedule_reachability_worker.ex +++ /dev/null @@ -1,33 +0,0 @@ -# Pleroma: A lightweight social networking server -# Copyright © 2017-2022 Pleroma Authors -# SPDX-License-Identifier: AGPL-3.0-only - -defmodule Pleroma.Workers.Cron.ScheduleReachabilityWorker do - use Oban.Worker, - queue: :background, - max_attempts: 2 - - alias Pleroma.Instances - alias Pleroma.Repo - - @impl true - def perform(_job) do - unreachable_servers = Instances.get_unreachable() - - jobs = - unreachable_servers - |> Enum.map(fn {domain, _} -> - Pleroma.Workers.ReachabilityWorker.new(%{"domain" => domain}) - end) - - case Repo.transaction(fn -> - Enum.each(jobs, &Oban.insert/1) - end) do - {:ok, _} -> - :ok - - {:error, reason} -> - {:error, reason} - end - end -end