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

auto-sync: 2026-04-21 17:20:01

Browse Source
This commit is contained in:
Stream
2026-04-21 17:20:01 +03:00
parent 185642ccda
commit 591bb316b9
1 changed files with 18 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
tasks/flightradar24/ingest/mart/build_mart.py
View File

@@ -204,7 +204,7 @@ def find_fr24_track(conn, flight_number: str, flight_date: date,
if not rows:
return None
# Route match REQUIRED for numeric-only matching (avoids e.g. DP6807 → SU6807)
# Full route match (preferred)
if origin_iata and destination_iata:
for row in rows:
orig_iata = ICAO_TO_IATA.get(row[2])
@@ -212,7 +212,14 @@ def find_fr24_track(conn, flight_number: str, flight_date: date,
if orig_iata == origin_iata and dest_iata == destination_iata:
return (row[0], row[1])
# No route match — do not return a wrong track
# Soft match: only origin known (destination_iata is NULL in schedule)
if origin_iata and not destination_iata:
for row in rows:
orig_iata = ICAO_TO_IATA.get(row[2])
if orig_iata == origin_iata:
return (row[0], row[1])
# No match
return None
@@ -265,7 +272,7 @@ def find_fa_track(conn, flight_number: str, flight_date: date,
if not rows:
return None
# Route match REQUIRED for numeric-only matching
# Full route match (preferred)
if origin_iata and destination_iata:
for row in rows:
orig_iata = ICAO_TO_IATA.get(row[2])
@@ -273,7 +280,14 @@ def find_fa_track(conn, flight_number: str, flight_date: date,
if orig_iata == origin_iata and dest_iata == destination_iata:
return (row[0], row[1])
# No route match — do not return a wrong track
# Soft match: only origin known (destination_iata is NULL in schedule)
if origin_iata and not destination_iata:
for row in rows:
orig_iata = ICAO_TO_IATA.get(row[2])
if orig_iata == origin_iata:
return (row[0], row[1])
# No match
return None