[ka2] fix connecteur imt_ag_tremblant: /api/stats publie disabled_sources (inactif+pause) pour que la supervision api-ka passe les sources retirées en retired au lieu de stale
1 changed file +7 −1
modified
immoka/web.py
+7 −1
@@ -510,6 +510,12 @@ def stats(syncs_since_h: float | None = None): | ||
| 510 | 510 | # --- écart prix demandé vs estimation Vrai-Prix, par bannière ----------- |
| 511 | 511 | registry = json.loads(SOURCES_PATH.read_text(encoding="utf-8"))["sources"] |
| 512 | 512 | source_names = {s["id"]: s["name"] for s in registry} |
| 513 | + # Sources volontairement sans sync (retirées ou en pause dans le registre) : | |
| 514 | + # publiées à la supervision api-ka via `disabled_sources`, qui les passe en | |
| 515 | + # « retired » au lieu de les signaler stale à répétition. Réversible : dès | |
| 516 | + # qu'une source réapparaît dans le journal de sync, api-ka la réévalue. | |
| 517 | + disabled_sources = sorted( | |
| 518 | + s["id"] for s in registry if s.get("status") in ("inactif", "pause")) | |
| 513 | 519 | deltas: dict[str, list[float]] = {} |
| 514 | 520 | for r in con.execute( |
| 515 | 521 | "SELECT source, price," |
@@ -552,7 +558,7 @@ def stats(syncs_since_h: float | None = None): | ||
| 552 | 558 | finally: |
| 553 | 559 | con2.close() |
| 554 | 560 | return {**dict(row), "vraiprix": vraiprix, "qualite": qualite, |
| 555 | − "recent_syncs": log} | |
| 561 | + "disabled_sources": disabled_sources, "recent_syncs": log} | |
| 556 | 562 | |
| 557 | 563 | |
| 558 | 564 | # --- Module Stats commun Groupe KA (voir frontend/src/ka/stats/SPEC.md) ------ |
| 559 | 565 | |