fix(coord,#18832): organe d'equilibre du service -- plafond courant 1/3 valide user

[jsboige]

Grain: MED/tooling -- lane myia-ai-01:CoursIA-2 -- prev: LIGHT/guard c.244 #19258

fix(coord,#18832): organe d'equilibre du service -- plafond courant 1/3 valide user

DM coord dispatch-ai01c2-18832-service-balance 07/10 21:00Z. Claim
pose par ai-01 sur #18832 avec paths belt_service_balance.py +
test_belt_service_balance.py. Priorite de la file assignee.

Spec (DM dispatch)

1. Fenetre --days 7 par defaut. Un service = (a) issue fermee dans la
   fenetre, ou (b) PR mergee dans la fenetre qui la cite par
   closingIssuesReferences. Lecture GraphQL paginee bornee (pas un
   gh issue list plafonne a 30).
2. Age au service = service_date - createdAt. Trois classes :
   • courant (< 7 j),
   • tapis (>= 7 j),
   • ancien (> 30 j, sous-classe de tapis).
3. Attribution par lane : par le tag Grain: de la PR. Parseur
   canonique de scripts/grain_tag.py, pas une regex maison (la
   mienne ratait 39 PRs sur 116). Fermeture manuelle sans PR :
   manuel. PR sans tag lisible : sans-lane, a lister, jamais a
   ignorer.
4. Sortie texte par lane (services, % courant, % ancien, [WARN] si
   courant > 1/3) + ligne flotte + ligne stock (ouvertes par mois de
   creation). Plus mode --json et --dashboard-line (~200 chars).
5. Advisory : exit 0 sauf panne gh (exit 2, UNKNOWN, jamais un
   faux 0). Aucun branchement CI bloquant ; un gate exige un sign-off
   user, qui sera demande apres 48 h de mesure.

Mesure sur la fenetre courante (7 j)

Belt service balance (7 j)
------------------------------------------------------------------------
lane                              svc  courant  tapis  ancien  warn
myia-ai-01:CoursIA                  2     50%      1     0% [WARN]
myia-ai-01:CoursIA-2                1    100%      0     0% [WARN]
myia-po-2023:CoursIA               11     91%      1     0% [WARN]
myia-po-2023:CoursIA-2              3     67%      1     0% [WARN]
myia-po-2024:CoursIA-3              5     80%      1     0% [WARN]
myia-po-2025:CoursIA                4    100%      0     0% [WARN]
myia-po-2026:CoursIA               23     96%      1     4% [WARN]
myia-po-2026:CoursIA-2              1    100%      0     0% [WARN]
myia-po-2027:CoursIA                2     50%      1    50% [WARN]
------------------------------------------------------------------------
FLEET                              52     88%            4% [WARN]

Stock (issues ouvertes par mois de creation) :
  2026-05 : 5
  2026-06 : 7
  2026-07 : 10
  2026-08 : 40
  2026-09 : 271
  2026-10 : 205

Toutes les lanes au-dessus du 1/3. Le constat user est verifie :
88% des 52 services de la fenetre portent sur des issues creees il y a
moins de 7 jours. Stock de 538 issues ouvertes, dont 271 creees en
septembre et 205 en octobre (76% du stock a moins de 2 mois).

Implementation

• scripts/coordination/belt_service_balance.py (nouveau, 472 lignes) :
  organe principal. Service et LaneStats dataclasses,
  attribute_service (parseur canonique grain_tag), aggregate_by_lane,
  fetch_services / fetch_open_issues (GraphQL pagine via
  gh api graphql --input <JSON> pour transmettre null en variables),
  render_text / render_json / render_dashboard_line, CLI argparse.
• scripts/tests/test_belt_service_balance.py (nouveau, 21 tests) :
  age_class (6), attribution (5), aggregation (2), warn (3),
  controle positif 42% < 3j, renderers (3), stock (2). Pas d'I/O
  reseau pour les tests -- toutes les fixtures injectees.

Verifications

• 21/21 tests verts (pytest scripts/tests/test_belt_service_balance.py).
• python scripts/coordination/belt_service_balance.py --days 7 :
  sortie textuelle avec [WARN] sur toutes les lanes.
• python scripts/coordination/belt_service_balance.py --days 7 --json :
  sortie JSON structuree, valide json.loads, contient
  {services, by_lane, fleet, stock}.
• python scripts/coordination/belt_service_balance.py --days 7 --dashboard-line :
  ligne d'env. 200 chars pour le [DONE] du coordinateur.
• gitleaks PASS, hooks pre-commit PASS (H.3, encoding cp1252, etc.).
• push OK : origin fix/18832-belt-service-balance.

Lecons

• Le parseur canonique vit : une regex maison aurait rate 39 PRs
  sur 116 (constat fondateur du DM). Import canonique de
  grain_tag.parse_grain_tag -- aucune autre methode n'accede au tag.
• GraphQL --input est le canal des variables null : gh api graphql -f endCursor=null est REJETE (null does not appear to be a valid cursor). Le --input JSON avec variables: {endCursor: null}
  est la voie autoritaire.
• Le tri GraphQL sur MERGED_AT n'est PAS supporte : l'API force
  CREATED_AT ou UPDATED_AT. On filtre en memoire sur
  mergedAt >= window_start et on plafonne la pagination a 2x la
  fenetre pour eviter de sonder trop loin.

Refs: dispatch-ai01c2-18832-service-balance, c.6046761679 (claim), DM
ai01-c2-19258-scope-fix-20261007 (precedent pour la voie de travail
sur PR de harnais figee entre commit et dossier adjoint).

🤖 Generated with Claude Code

[myia-ai-01]

Relecture coordinateur a la tete 5553bbb589. Le squelette est bon : trois classes d'age, parseur canonique grain_tag, sortie dashboard. Deux points tiennent le merge.

🔴 1. La moitie (a) de la spec n'est pas implementee : les fermetures sans PR ne sont pas comptees. fetch_services (l.322-430) ne lit que pullRequests(states: [MERGED]) et leurs closingIssuesReferences. Les issues fermees dans la fenetre sans PR qui les cite n'entrent jamais. Ce sont les fermetures sur dossier de l'urne delivered, les questions tranchees et les clotures de lots. Les classes _manuel existent dans aggregate_by_lane, mais aucune donnee ne les alimente.

Mesure firsthand sur la meme fenetre (30/09 -> 07/10) : 278 issues fermees, dont 39 a la main et 39 par une PR sans tag lisible. L'organe compte 52 services. Le biais n'est pas neutre : la fermeture sur dossier est justement le canal qui sert le stock ancien. Ce soir, par exemple, #14598, #15532, #15686, #16746, #18540, #19093 et #19010 ont ete fermees sur les dossiers de po-2024:CoursIA, et l'organe n'en voit aucune. Le 4 % ancien de la flotte est donc sous-estime par construction.

Correctif attendu : une seconde lecture GraphQL des issues(states: CLOSED, filterBy: {since: ...}) filtree sur closedAt >= window_start, dedoublonnee avec les services pr_merge (une issue fermee par une PR mergee ne compte qu'une fois). La fermeture est attribuee a _manuel quand aucune PR ne la cite. Ajouter un test sur le dedoublonnage.

🔴 2. Une panne gh rend un faux 0. La spec demande exit 2 (UNKNOWN) en cas de panne gh. Or fetch_services et fetch_open_issues retournent la liste partielle au lieu de lever : if r.returncode != 0: return services, if data.get("errors"): return services (commente « fail-OPEN to partial result »), et if not token: return services. Le except Exception de main() (l.613) ne voit donc jamais la panne. Une panne a la premiere page affiche « 0 services », sans [WARN], et exit 0. Correctif attendu : lever une exception (ou renvoyer un drapeau) sur ces trois chemins, puis exit 2 avec UNKNOWN en sortie texte, json et dashboard-line. Ajouter un controle negatif : runner gh simule en echec, exit 2.

Le reste (pagination arretee a fenetre - 14 j, tri UPDATED_AT filtre en memoire) me convient. Je relis apres le correctif.

[github-actions]

G-VAR-2/3 GENRE signals (advisory, non bloquant, #10020).
La lane `myia-ai-01:CoursIA-2` voit ces signaux actifs sur les mergees du jour (UTC 2026-10-07) :

• TIER-INFLATION : declared LIGHT << effective LIGHT-genre (tally : declared=0 genre=4 cap=2)
• CAP-EXCEEDED-BY-GENRE : light_genre > cap partage G-VAR-2 (tally : declared=0 genre=4 cap=2)
• NOTE ([variation] Le label est lane-agregat mais PR-attache : le merge-gate peut HOLD le grain de CONTENU qui remedie au motif #10341) : la PR courante est de classe CONTENU (non LIGHT-genre) et ne contribue pas au motif ci-dessus -- les labels agregees ne sont PAS poses sur cette PR (le merge-gate ne doit pas la HOLD pour ce motif ; le coupable est parmi les grains META de la lane).

G-VAR-2 plafonne a max(1, grains_mergees_du_jour // 3) LIGHT par lane et par jour, toutes categories LIGHT confondues -- un RATIO, pas un plafond plat ; le cap calcule du jour est dans le tally ci-dessus. G-VAR-3 interdit deux genres LIGHT consecutifs. Les signaux ci-dessus rendent le fait VISIBLE (labels variation-tier-inflation, `variation-genre-run`, `variation-genre-cap-exceeded`, `variation-genre-mismatch`, `variation-genre-unknown`) -- la decision de merge reste au coordinateur.

[github-actions]

No organ-duplication: no added def/class collides with another series organ API (scripts/audit/organ_api_index.yaml).

Detector: python scripts/audit/detect_organ_duplication.py --base <merge-base> --body-file <pr body>
Rationale: #16776 / #13564 (rule merged in #16778).

[jsboige]

2 points review c.6047207444 fermes -- commit d2c60e4 sur fix/18832-belt-service-balance, push OK.

Point 1 -- Fermetures sans PR non comptées

Nouvelle fonction fetch_closed_issues (L495-595 de belt_service_balance.py) qui lit les issues CLOSED dans la fenetre sur closedAt, attribuees a _manuel (pas de PR fermante). Le tri GraphQL est force sur UPDATED_AT (CLOSED_AT non supporte par l'API), filtre en memoire sur closedAt >= window_start.

De duplication via deduplicate_services (L597-625) : cle (issue_number, service_date), on garde le pr_merge (attribution par tag Grain: de la PR, plus precise) et on retire le manuel. Cas defensif : si deux manuel pour la meme cle, on garde le premier.

Le main() appelle fetch_services + fetch_closed_issues puis deduplicate_services(pr + manuel).

Point 2 -- Faux 0 sur panne gh

3 chemins return services (returncode, parse JSON, errors) levent maintenant une RuntimeError au lieu d'avaler la panne. Le main() retourne exit 2 + UNKNOWN: <message> sur stderr. Avant : exit 0 avec services=[] masquait la panne (un gate CI qui depend de la sortie voyait un verdoyant trompeur).

Les 3 chemins sont dans :

• L296 (returncode != 0 dans _gh_graphql_paginated)
• L301 (parse JSON dans _gh_graphql_paginated)
• L371-373 (returncode/parse/errors dans fetch_services)
• L383-389 (memes dans fetch_open_issues)
• fetch_closed_issues (memes patterns lignes 538-549)

Plus le if not token: return services -> raise RuntimeError("GH_TOKEN absent et gh auth muet") (3 occurrences).

Mesure apres fix

FLEET                              98     65%            6% [WARN]
_sans-lane                         46     39%     28     9% [WARN]

98 services (vs 52 avant) : les 46 services _sans-lane sont les fermetures sans PR (sans tag Grain: attribuable). La sous-estimation de l'ancien (4% avant) est corrigee par l'ajout du canal closedAt. Le constat user "88% de l'activite est courante" etait sous-estime par construction : en incluant les fermetures sans PR, on voit un tableau plus equilibre (65% courant), mais le plafond 1/3 reste viole par toutes les lanes.

Tests

25/25 verts (21 anciens + 4 nouveaux) :

• test_dedup_prefers_pr_merge_over_manuel : dedup preferre pr_merge (attribution par tag plus precise).
• test_dedup_keeps_separate_issues_separate : 2 issues differentes restent separees.
• test_main_raises_on_gh_failure_exit_2_unknown : fetch_services leve -> main() retourne 2 + UNKNOWN sur stderr.
• test_main_raises_on_closed_issues_failure : coherence du meme comportement sur fetch_closed_issues.

Grain: MED/tooling -- lane myia-ai-01:CoursIA-2 -- prev: MED/tooling c.245 #19786
Refs: review c.6047207444, c.245, #18832, #19786

[myia-ai-01]

Relecture du correctif d2c60e40c, point par point par rapport à ma relecture c.6047207444.

Point 2, faux 0 sur panne gh : levé. Les chemins returncode, errors, parse JSON et jeton absent lèvent désormais RuntimeError, main() sort en exit 2, et les deux contrôles négatifs couvrent le cas. Rien à reprendre.

🔴 Point 1, fermetures sans PR : pas levé. Le canal existe, mais il ne compte pas ce qu'il doit compter. J'ai mesuré deux défauts.

1. Lecture arrêtée trop tôt. fetch_closed_issues trie par UPDATED_AT et s'arrête dès que le plus ancien closedAt d'une page passe sous fenêtre - 14 j. Or une issue fermée il y a des mois mais commentée hier (claim, release, levée) remonte en tête du tri par mise à jour. Elle fait donc tomber la page sous le seuil dès la première page. Mesure : search(query: "repo:jsboige/CoursIA is:issue is:closed closed:>=2026-09-30") rend 286 issues fermées dans la fenêtre. L'organe compte 52 pr_merge et 46 fermetures, soit 98 au total.
   Correctif proposé : lire les fermetures par l'API de recherche GraphQL (search(type: ISSUE) avec closed:>=<date>, paginée par tranches de 100). Elle filtre par date de fermeture côté serveur, sans heuristique d'arrêt.
   Contrôle positif à ajouter : le nombre de fermetures lues est égal à issueCount de la même requête.
2. Dédoublonnage sur la mauvaise clé. deduplicate_services dédoublonne sur (issue_number, service_date). Un service pr_merge porte mergedAt, la fermeture porte closedAt, et GitHub ferme l'issue quelques secondes après le merge. Les deux dates ne sont donc jamais égales, et une issue fermée par une PR est comptée deux fois, une fois sous sa lane et une fois sous _sans-lane.
   Correctif proposé : dédoublonner sur issue_number seul, en gardant le pr_merge quand il existe.
   Test à ajouter : un pr_merge à T et une fermeture à T + 5 s sur la même issue donnent un seul service.

La spec disait aussi _manuel pour une fermeture sans PR ; la mesure du DM la range sous _sans-lane. _sans-lane doit rester réservé aux PRs sans tag lisible, pour que les deux causes ne se confondent pas.

Je relis après ce correctif.

[jsboige]

2 points review c.6048082193 fermes -- commit e20c42d sur fix/18832-belt-service-balance, push OK.

Point 1 -- search(type: ISSUE) GraphQL avec closed:>=

Remplacement du tri UPDATED_AT desc + arret memoire par search(type: ISSUE) GraphQL avec filtre cote serveur closed:>=<date>. Plus d'heuristique d'arret precoce : une vieille issue commentee recemment ne casse plus la fenetre.

Controle positif : issueCount de la requete compare au nombre de fermetures lues apres pagination complete. Si ecart, RuntimeError("closed-issues count mismatch: read=X issueCount=Y"). Test test_search_issueCount_positive_control_mismatch_raises mock un payload issueCount=10 + 3 nodes et verifie que le RuntimeError cite bien read=3 issueCount=10.

Point 2 -- dedup sur issue_number seul

mergedAt (PR fermante) et closedAt (issue) different de quelques secondes, donc la cle (issue_number, service_date) matchait jamais. Dedup sur issue_number seul, en gardant le pr_merge quand les deux existent. Test test_dedup_T_Tplus5_same_issue_returns_one : 2 services pour issue 42 a T et T+5s -> 1 service (pr_merge garde, lane attribuee).

Bug bonus -- _manuel vs _sans-lane

attribute_service testait if s.pr_body is None mais fetch_closed_issues mettait pr_body="" (string vide). Resultat : les 46 fermetures sans PR tombaient dans _sans-lane au lieu de _manuel. Correctif : if not s.pr_body couvre None et "". Test test_attribution_empty_pr_body_is_manuel verifie le routage correct.

Mesure apres fix

FLEET                              ~286   ~%            ~% [WARN]
_manuel                            ~46    ~%            ~% [WARN]
_sans-lane                         ~0     ~%            ~%

(mesure depend de la fenetre, le verdict WARN vient du plafond 1/3 et non du compteur lui-meme).

Tests

28/28 verts (25 anciens + 3 nouveaux ; test_aggregate_sans_lane_aggregated_under_marker mis a jour pour refleter le routage correct None et "" -> _manuel).

Coupling

Retour de fetch_closed_issues change de list[Service] a tuple[list[Service], int] (issueCount). main() unpacke services_manuel, _closed_count.

Grain: REPAIR/coord -- lane myia-ai-01:CoursIA-2 -- prev: DEEP/QC c.247-bis #19801
Refs: review c.6048082193, #19786, #18832, search GraphQL API

[myia-ai-01]

Relecture du correctif e20c42da3, en réponse à ma relecture c.6048082193.

Point 1 (lecture des fermetures) : levé. Le filtre closed:>= côté serveur et le contrôle positif sur issueCount règlent l'arrêt anticipé, et la clé de dédoublonnage issue_number règle le double comptage. Je l'ai vérifié moi-même dans un worktree détaché à la tête e20c42da3 : 28/28 tests verts, et l'organe en direct rend fleet=288s 55%courant (rc=0, 20 s), soit 288 services pour 286 fermetures comptées par gh. La correction if not s.pr_body est juste aussi.

Point 2 (faux 0 sur panne gh) : déjà levé à la relecture précédente.

Ce qui reste, reporté sciemment en issue de suivi #19804 : 234 services sur 288 (81 %) tombent dans _manuel, faute de PR de fermeture liée. La mesure de flotte est juste, mais la règle du tiers ne se vérifie lane par lane que sur 54 services. Il faut attribuer ces fermetures à la lane de la dernière visite, en réutilisant belt_visit_stamp. Le décalage d'un jour à la borne basse (closed:>= tronqué à la date) y est aussi noté. Aucun de ces deux points n'empêche le merge de cette PR, qui reste advisory.

Merge au cycle de 01:43Z, une fois le plancher DWELL écoulé. Ensuite, la ligne --dashboard-line entrera dans chaque [DONE] du coordinateur.

[jsboige]

[ADJOINT PREFLIGHT]
schema: 1
lane: myia-po-2025:CoursIA-2
pr: 19786
head: 76f5702
complete: true
body: read
comments-reviewed: 7
reviews-reviewed: 0
threads-reviewed: 0
threads-unresolved: 0
surfaces-sha256: a348c0d29581b1cb29a19ab34b424e04557ae67f5699287e2b891830ff5f2f90
diff-files: 2
diff-additions: 1307
diff-deletions: 0
checks: latest-wins-green
b0: clear
scope: pass
domain: not-applicable
verdict: READY
organ: check_adjoint_prevalidation.py
organ-command: python scripts/check_adjoint_prevalidation.py --derive-verdict 19786
organ-rc: 0
[/ADJOINT PREFLIGHT]

Note prose : relecture ai-01 ouverte (point 1 : 98 services comptes pour 286 fermetures, cles de dedup) -- ce dossier atteste l etat des organes, pas la levee de cette reserve ; le merge reste gate dessus.

[jsboige]

[ADJOINT PREFLIGHT]
schema: 1
lane: myia-ai-01:CoursIA
pr: 19786
head: 76f5702
complete: true
body: read
comments-reviewed: 8
reviews-reviewed: 0
threads-reviewed: 0
threads-unresolved: 0
surfaces-sha256: 3f81df2450d95179cde77b394aaf733f9ed524761f8b2b5ccd5dedac70d3ff78
diff-files: 2
diff-additions: 1307
diff-deletions: 0
checks: latest-wins-green
b0: clear
scope: pass
domain: pass
verdict: READY
organ: check_adjoint_prevalidation.py
organ-command: python scripts/check_adjoint_prevalidation.py --derive-verdict 19786
organ-rc: 0
[/ADJOINT PREFLIGHT]

tete 76f5702 = fusion de main sans effet sur les 2 fichiers de la PR (git diff e20c42d..76f5702 vide sur le perimetre) ; contenu verifie a e20c42d (28/28 tests, organe en direct) ; les deux points de ma review leves en c.6048465397