Broadcast weather:updated PubSub after HRRR profiles stored
This commit is contained in:
parent
0dd695c574
commit
10390f3d07
1 changed files with 7 additions and 0 deletions
|
|
@ -69,6 +69,13 @@ defmodule Microwaveprop.Workers.PropagationGridWorker do
|
||||||
end) do
|
end) do
|
||||||
{:ok, grid_data} ->
|
{:ok, grid_data} ->
|
||||||
store_hrrr_profiles(grid_data, valid_time)
|
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)
|
scores = compute_scores(grid_data, valid_time)
|
||||||
|
|
||||||
case Propagation.upsert_scores(scores, prune: false) do
|
case Propagation.upsert_scores(scores, prune: false) do
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue