Flights: Vollstaendigkeit vor Aktualitaet

Batch-Pause 3s -> 5s, Refresh-Zyklus 60s -> 180s, Cache 45s -> 170s.
Alle 64 Stuetzpunkte werden vollstaendig abgefragt bevor Cache erneuert.
1.694 Flugzeuge global, alle Regionen abgedeckt.
Dieser Commit ist enthalten in:
Claude Dev
2026-03-24 11:47:02 +01:00
Ursprung cbb6596513
Commit a22a4e70d1

Datei anzeigen

@@ -32,7 +32,7 @@ import random
async def _fetch_all(): async def _fetch_all():
"""Holt Flugdaten fuer alle Stuetzpunkte.""" """Holt Flugdaten fuer alle Stuetzpunkte."""
now = time.time() now = time.time()
if _cache["data"] and now - _cache["ts"] < 45: if _cache["data"] and now - _cache["ts"] < 170:
return _cache["data"] return _cache["data"]
async with _lock: async with _lock:
@@ -61,7 +61,7 @@ async def _fetch_all():
except Exception: except Exception:
errors += 1 errors += 1
if i + 3 < len(grid): if i + 3 < len(grid):
await asyncio.sleep(3.0) await asyncio.sleep(5.0)
_cache["data"] = {"ac": list(seen.values()), "total": len(seen), "errors": errors} _cache["data"] = {"ac": list(seen.values()), "total": len(seen), "errors": errors}
_cache["ts"] = time.time() _cache["ts"] = time.time()
@@ -77,7 +77,7 @@ async def _collector_loop():
await _fetch_all() await _fetch_all()
except Exception as e: except Exception as e:
logger.warning(f"Flight collector error: {e}") logger.warning(f"Flight collector error: {e}")
await asyncio.sleep(60) await asyncio.sleep(180)
def start_flight_collector(): def start_flight_collector():