diff --git a/lib/microwaveprop/workers/propagation_grid_worker.ex b/lib/microwaveprop/workers/propagation_grid_worker.ex index 593401f4..31c8af6b 100644 --- a/lib/microwaveprop/workers/propagation_grid_worker.ex +++ b/lib/microwaveprop/workers/propagation_grid_worker.ex @@ -69,6 +69,13 @@ defmodule Microwaveprop.Workers.PropagationGridWorker do end) do {:ok, grid_data} -> store_hrrr_profiles(grid_data, valid_time) + + Phoenix.PubSub.broadcast( + Microwaveprop.PubSub, + "weather:updated", + {:weather_updated, valid_time} + ) + scores = compute_scores(grid_data, valid_time) case Propagation.upsert_scores(scores, prune: false) do