graham/prop
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore(prop): stop seeding grid_tasks until Rust is validated

Browse source 
Option A from the shadow-mode duplication discussion — Elixir still
owns f00-f18 fan-out via Oban and writes to /data/scores. The Rust
worker sits idle polling an empty grid_tasks table instead of
re-fetching the same HRRR GRIB2 and writing a parallel tree to
/data/scores_shadow.

Brings the seed call back when Phase 2 cutover is approved (at which
point the Elixir fan-out shrinks to fh=0 and PROP_SCORES_DIR flips
from /data/scores_shadow to /data/scores).
This commit is contained in:
Graham McIntire 2026-04-19 16:14:17 -05:00
parent 5692d50a72
commit 03ba48fe36
No known key found for this signature in database
GPG key ID: F4ABF488E6029E59
1 changed files with 4 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lib/microwaveprop/workers/propagation_grid_worker.ex
View file

@ -45,7 +45,6 @@ defmodule Microwaveprop.Workers.PropagationGridWorker do
alias Microwaveprop.Propagation
alias Microwaveprop.Propagation.BandConfig
alias Microwaveprop.Propagation.Grid
alias Microwaveprop.Propagation.GridTaskEnqueuer
alias Microwaveprop.Propagation.ProfilesFile
alias Microwaveprop.Propagation.ScoreCache
alias Microwaveprop.Weather
@ -98,13 +97,10 @@ defmodule Microwaveprop.Workers.PropagationGridWorker do
Oban.insert_all(jobs)
# Seed the grid_tasks table in parallel so the Rust `prop-grid-rs`
# worker can pick up f01..f18 from a shared NFS mount. During Phase
# 1 shadow mode this runs alongside the Elixir chain; the Rust
# writes land in /data/scores_shadow and are diffed by
# `ShadowComparator`. At cutover the Elixir fan-out above is
# trimmed to just fh=0.
_ = GridTaskEnqueuer.seed(run_time)
# `GridTaskEnqueuer.seed/1` feeds the Rust `prop-grid-rs` worker via
# grid_tasks. Disabled until the Rust image is validated end-to-end
# on talos5 — once cutover is approved, the Elixir fan-out above
# shrinks to just fh=0 and this line comes back.
:ok
end