admin/wiki
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

auto-sync: 2026-04-20 09:40:01

Browse Source
This commit is contained in:
Stream
2026-04-20 09:40:01 +03:00
parent bfcb028189
commit 5c09319618
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
tasks/flightradar24/ingest/preprocess/main.py
View File

@@ -309,6 +309,7 @@ def process_batch(conn, packets: list, aircraft_state: dict) -> int:
aircraft_state[icao24]["vrate"] = float(parsed["vrate"])
if onground is not None:
aircraft_state[icao24]["onground"] = onground
aircraft_state[icao24]["velocity_ts"] = observed_at
# update onground from any message
if onground is not None and icao24 in aircraft_state:
@@ -317,11 +318,17 @@ def process_batch(conn, packets: list, aircraft_state: dict) -> int:
# for MSG3: enrich with cached velocity
if msg_type == "3":
cached = aircraft_state.get(icao24, {})
if speed is None:
velocity_ts = cached.get("velocity_ts")
# use cached velocity only if it's fresh (< 30 sec old)
velocity_fresh = (
velocity_ts is not None and
(observed_at - velocity_ts).total_seconds() < 30
)
if speed is None and velocity_fresh:
speed = cached.get("speed")
if heading is None:
if heading is None and velocity_fresh:
heading = cached.get("heading")
if vrate is None:
if vrate is None and velocity_fresh:
vrate = cached.get("vrate")
if onground is None:
onground = cached.get("onground")