diff --git a/lib/mix/tasks/backtest.ex b/lib/mix/tasks/backtest.ex index f1b1e9e4..54a09ec6 100644 --- a/lib/mix/tasks/backtest.ex +++ b/lib/mix/tasks/backtest.ex @@ -32,6 +32,7 @@ defmodule Mix.Tasks.Backtest do @impl Mix.Task def run(argv) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) {opts, _, _} = OptionParser.parse(argv, diff --git a/lib/mix/tasks/era5_backfill.ex b/lib/mix/tasks/era5_backfill.ex index 66a93529..0b220e7a 100644 --- a/lib/mix/tasks/era5_backfill.ex +++ b/lib/mix/tasks/era5_backfill.ex @@ -27,6 +27,7 @@ defmodule Mix.Tasks.Era5Backfill do @impl Mix.Task def run(args) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) limit = case args do diff --git a/lib/mix/tasks/hrrr_backfill.ex b/lib/mix/tasks/hrrr_backfill.ex index 416e221d..6abae969 100644 --- a/lib/mix/tasks/hrrr_backfill.ex +++ b/lib/mix/tasks/hrrr_backfill.ex @@ -28,6 +28,7 @@ defmodule Mix.Tasks.HrrrBackfill do @impl Mix.Task def run(args) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) {opts, _, _} = OptionParser.parse(args, switches: [all: :boolean, limit: :integer]) refetch_all? = Keyword.get(opts, :all, false) diff --git a/lib/mix/tasks/hrrr_climatology.ex b/lib/mix/tasks/hrrr_climatology.ex index 977caf00..18fdeff3 100644 --- a/lib/mix/tasks/hrrr_climatology.ex +++ b/lib/mix/tasks/hrrr_climatology.ex @@ -17,6 +17,7 @@ defmodule Mix.Tasks.HrrrClimatology do @impl Mix.Task def run(argv) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) {opts, _, _} = OptionParser.parse(argv, switches: [min_samples: :integer]) min_samples = Keyword.get(opts, :min_samples, 3) diff --git a/lib/mix/tasks/hrrr_native_backfill.ex b/lib/mix/tasks/hrrr_native_backfill.ex index 5a87f186..b03084a8 100644 --- a/lib/mix/tasks/hrrr_native_backfill.ex +++ b/lib/mix/tasks/hrrr_native_backfill.ex @@ -26,6 +26,7 @@ defmodule Mix.Tasks.HrrrNativeBackfill do @impl Mix.Task def run(argv) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) {opts, _, _} = OptionParser.parse(argv, switches: [limit: :integer]) limit = Keyword.get(opts, :limit, 50) diff --git a/lib/mix/tasks/hrrr_native_derive.ex b/lib/mix/tasks/hrrr_native_derive.ex index f5646146..bc72426e 100644 --- a/lib/mix/tasks/hrrr_native_derive.ex +++ b/lib/mix/tasks/hrrr_native_derive.ex @@ -23,6 +23,7 @@ defmodule Mix.Tasks.HrrrNativeDeriveFields do @impl Mix.Task def run(argv) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) {opts, _, _} = OptionParser.parse(argv, switches: [limit: :integer]) limit = Keyword.get(opts, :limit, 10_000) diff --git a/lib/mix/tasks/reset_enrichment.ex b/lib/mix/tasks/reset_enrichment.ex index 80a76663..0047c893 100644 --- a/lib/mix/tasks/reset_enrichment.ex +++ b/lib/mix/tasks/reset_enrichment.ex @@ -21,6 +21,7 @@ defmodule Mix.Tasks.ResetEnrichment do @impl Mix.Task def run(_args) do Mix.Task.run("app.start") + Oban.pause_all_queues(Oban) {count, _} = Contact