diff --git a/lib/microwaveprop/workers/hrrr_fetch_worker.ex b/lib/microwaveprop/workers/hrrr_fetch_worker.ex index 92a0f35e..587f3a94 100644 --- a/lib/microwaveprop/workers/hrrr_fetch_worker.ex +++ b/lib/microwaveprop/workers/hrrr_fetch_worker.ex @@ -1,6 +1,6 @@ defmodule Microwaveprop.Workers.HrrrFetchWorker do @moduledoc false - use Oban.Worker, queue: :hrrr, max_attempts: 20 + use Oban.Worker, queue: :hrrr, max_attempts: 20, unique: [period: 3600] alias Microwaveprop.Weather alias Microwaveprop.Weather.HrrrClient diff --git a/lib/microwaveprop/workers/terrain_profile_worker.ex b/lib/microwaveprop/workers/terrain_profile_worker.ex index 299d6ec5..69660801 100644 --- a/lib/microwaveprop/workers/terrain_profile_worker.ex +++ b/lib/microwaveprop/workers/terrain_profile_worker.ex @@ -1,6 +1,6 @@ defmodule Microwaveprop.Workers.TerrainProfileWorker do @moduledoc false - use Oban.Worker, queue: :terrain, max_attempts: 20 + use Oban.Worker, queue: :terrain, max_attempts: 20, unique: [period: 3600] alias Microwaveprop.Radio alias Microwaveprop.Terrain diff --git a/lib/microwaveprop/workers/weather_fetch_worker.ex b/lib/microwaveprop/workers/weather_fetch_worker.ex index 1a1886ba..38f74e0e 100644 --- a/lib/microwaveprop/workers/weather_fetch_worker.ex +++ b/lib/microwaveprop/workers/weather_fetch_worker.ex @@ -1,6 +1,6 @@ defmodule Microwaveprop.Workers.WeatherFetchWorker do @moduledoc false - use Oban.Worker, queue: :weather, max_attempts: 20 + use Oban.Worker, queue: :weather, max_attempts: 20, unique: [period: 3600] alias Microwaveprop.Repo alias Microwaveprop.Weather