matt/meshai
1
0
Fork 0
mirror of https://github.com/zvx-echo6/meshai.git synced 2026-06-11 01:14:45 +02:00
Code Issues Projects Releases Packages Wiki Activity

fix(wfigs): set all fire broadcasts to immediate severity

Browse source 
Fire events are already change-detected by the wfigs handler so the
grouper coalescing window adds no value and causes commit callbacks
to be lost when events are replaced. Setting severity to immediate
unconditionally bypasses the grouper entirely.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
Matt Johnson (via Claude) 2026-06-07 08:20:22 +00:00
commit dea86883db
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
meshai/central/wfigs_handler.py
View file

@ -152,7 +152,7 @@ def handle_wfigs(normalized: dict, envelope: dict, subject: str,
data["category"] = "wildfire_declared" data["category"] = "wildfire_declared"
# v0.6-3c: severity override for fire broadcasts # v0.6-3c: severity override for fire broadcasts
if isinstance(data, dict): if isinstance(data, dict):
data["_severity_override"] = "immediate" if (acres and acres > 1000) or contained_pct == 0 else "priority" data["_severity_override"] = "immediate"
_attach_commit_handles(data, irwin_id=irwin_id, _attach_commit_handles(data, irwin_id=irwin_id,
acres=acres, contained_pct=contained_pct, acres=acres, contained_pct=contained_pct,
event_log_row_id=log_id) event_log_row_id=log_id)
@ -175,7 +175,7 @@ def handle_wfigs(normalized: dict, envelope: dict, subject: str,
data["category"] = "wildfire_declared" data["category"] = "wildfire_declared"
# v0.6-3c: severity override for fire broadcasts # v0.6-3c: severity override for fire broadcasts
if isinstance(data, dict): if isinstance(data, dict):
data["_severity_override"] = "immediate" if (acres and acres > 1000) or contained_pct == 0 else "priority" data["_severity_override"] = "immediate"
_attach_commit_handles(data, irwin_id=irwin_id, _attach_commit_handles(data, irwin_id=irwin_id,
acres=acres, contained_pct=contained_pct, acres=acres, contained_pct=contained_pct,
event_log_row_id=log_id) event_log_row_id=log_id)
@ -219,7 +219,7 @@ def handle_wfigs(normalized: dict, envelope: dict, subject: str,
last_bcast_contained=last_bcast_contained) last_bcast_contained=last_bcast_contained)
# v0.6-3c: severity override for fire updates # v0.6-3c: severity override for fire updates
if isinstance(data, dict): if isinstance(data, dict):
data["_severity_override"] = "immediate" if (acres and acres > 1000) or contained_pct == 0 else "priority" data["_severity_override"] = "immediate"
_attach_commit_handles(data, irwin_id=irwin_id, _attach_commit_handles(data, irwin_id=irwin_id,
acres=acres, contained_pct=contained_pct, acres=acres, contained_pct=contained_pct,
event_log_row_id=log_id) event_log_row_id=log_id)