diff --git a/lib/microwaveprop/weather/hrrr_client.ex b/lib/microwaveprop/weather/hrrr_client.ex index 20277302..0e0190b6 100644 --- a/lib/microwaveprop/weather/hrrr_client.ex +++ b/lib/microwaveprop/weather/hrrr_client.ex @@ -566,8 +566,13 @@ defmodule Microwaveprop.Weather.HrrrClient do timeout: 120_000 ) |> Enum.map(fn - {:ok, result} -> result - {:exit, reason} -> {:error, reason} + {:ok, result} -> + result + + {:exit, reason} -> + Logger.error("HRRR grib range download crashed (to_file): url=#{url} reason=#{inspect(reason)}") + + {:error, reason} end) case Enum.find(results, &match?({:error, _}, &1)) do @@ -612,8 +617,13 @@ defmodule Microwaveprop.Weather.HrrrClient do timeout: 120_000 ) |> Enum.map(fn - {:ok, result} -> result - {:exit, reason} -> {:error, reason} + {:ok, result} -> + result + + {:exit, reason} -> + Logger.error("HRRR grib range download crashed: url=#{url} reason=#{inspect(reason)}") + + {:error, reason} end) # Sort by offset and concatenate diff --git a/lib/microwaveprop/workers/gefs_fetch_worker.ex b/lib/microwaveprop/workers/gefs_fetch_worker.ex index a998426d..0cc13c4b 100644 --- a/lib/microwaveprop/workers/gefs_fetch_worker.ex +++ b/lib/microwaveprop/workers/gefs_fetch_worker.ex @@ -172,8 +172,15 @@ defmodule Microwaveprop.Workers.GefsFetchWorker do timeout: 30_000 ) |> Stream.flat_map(fn - {:ok, results} -> results - {:exit, _reason} -> [] + {:ok, results} -> + results + + {:exit, reason} -> + Logger.error( + "GefsFetch scoring task crashed: fh=#{fh} valid_time=#{inspect(valid_time)} reason=#{inspect(reason)}" + ) + + [] end) |> Enum.to_list()