SPB Git
spboucher.ai

Repository Public

spbjob-ka

Commit

[ka6] fix connecteur h2o_innovation: repli « détail seulement » pendant les maintenances nocturnes d'ADP WFN — cause de l'échec du 2026-08-29 22:19 : fenêtre de maintenance planifiée d'ADP Workforce Now du samedi soir (~22:00→02:00 ET, même événement systémique que cultures_genv a57f452 et groupe_nordik a17b979), pendant laquelle workforcenow.adp.com redirige vers sorry.adp.com et la liste job-requisitions renvoie du HTML (« Expecting value: line 1 column 1 »). Un seul passage raté + cycle ~3 h suffit à dépasser le seuil stale de 4 h. Fix (pattern cultures_genv/groupe_nordik/ciena) : si la liste échoue en 5xx/non-JSON, revalidation une à une des offres actives connues via l'API détail job-requisitions/<itemID> (réquisition complète live — aucune donnée inventée) ; 404 = offre retirée ; si RIEN n'est validable (maintenance totale) l'erreur d'origine est propagée (sync en échec, inventaire préservé). Le chemin liste normal reprend seul dès la fin de la maintenance. Tests réels : repli avec liste 502 simulée → 9 offres revalidées live ; run.py sync h2o_innovation (chemin normal) → ok, found=9 (= médiane 9.0), 9 actives en base. Corrige aussi le chemin erroné dans l'en-tête du fichier. pm2 restart job-ka-sync OK, site local 200, www.job-ka.com 200.

Simon-Pierre Boucher committed · Aug 30, 2026 parent a17b979
1 changed file +114 −3 Browse files
Unified Split
modified jobka/connectors/h2o_innovation.py +114 −3
@@ -2,11 +2,40 @@
2 # Job·Ka — Groupe KA 2 # Job·Ka — Groupe KA
3 # Auteur : Simon-Pierre Boucher 3 # Auteur : Simon-Pierre Boucher
4 # Contact : contact@spboucher.ai 4 # Contact : contact@spboucher.ai
5−# Fichier : jobka/connectors/jobka/connectors/h2o_innovation.py 5+# Fichier : jobka/connectors/h2o_innovation.py
6 # Rôle : Connecteur H2O Innovation — traitement de l'eau, Québec — ADP WFN 6 # Rôle : Connecteur H2O Innovation — traitement de l'eau, Québec — ADP WFN
7−# Créé : 2026-08-25 Modifié : 2026-08-25 7+# + repli « détail seulement » quand l'API liste échoue
8+# (maintenances nocturnes récurrentes d'ADP)
9+# Créé : 2026-08-25 Modifié : 2026-08-30
8 # ============================================================================= 10 # =============================================================================
9−from .adp import ADPWorkforceNowConnector 11+"""H2O Innovation — ADP Workforce Now, avec repli de revalidation.
12+
13+Contexte (2026-08-28/29) : ADP Workforce Now a des fenêtres de maintenance
14+nocturnes récurrentes (vendredi ET samedi soir ~22:00 → 02:00 ET) pendant
15+lesquelles TOUT workforcenow.adp.com redirige vers sorry.adp.com — la liste
16+job-requisitions renvoie alors du HTML, d'où le « Expecting value: line 1
17+column 1 » du sync de 22:19 (29/08). Comme le cycle complet met ~3 h entre
18+deux passages de la source, un seul passage raté pendant la fenêtre suffit à
19+dépasser le seuil stale de 4 h.
20+
21+D'où le repli ci-dessous (même pattern que cultures_genv.py /
22+groupe_nordik.py / ciena.py) : si la pagination liste échoue en 5xx ou en
23+non-JSON, on revalide une à une les offres actives connues en base via l'API
24+détail job-requisitions/<itemID> (qui renvoie la réquisition complète :
25+titre, date, lieux, description). Aucune donnée inventée — tout vient de la
26+réponse live. Une offre en 404 est considérée retirée. Si AUCUNE offre n'est
27+validable (maintenance totale : le détail redirige aussi vers
28+sorry.adp.com), l'erreur d'origine est propagée pour que le sync reste un
29+échec (inventaire préservé). Limite assumée : le repli ne découvre pas les
30+NOUVELLES offres — le chemin liste normal reprend seul au cycle suivant la
31+fin de la maintenance.
32+"""
33+from __future__ import annotations
34+
35+import requests
36+
37+from ..schema import JobPosting, clean_html
38+from .adp import _API, ADPWorkforceNowConnector
10 39
11 40
12 class H2oInnovationConnector(ADPWorkforceNowConnector): 41 class H2oInnovationConnector(ADPWorkforceNowConnector):
@@ -14,3 +43,85 @@ class H2oInnovationConnector(ADPWorkforceNowConnector):
14 EMPLOYER = "H2O Innovation" 43 EMPLOYER = "H2O Innovation"
15 CID = "7682e0ff-ab6e-4e2a-b4c4-4d3845982888" 44 CID = "7682e0ff-ab6e-4e2a-b4c4-4d3845982888"
16 CCID = "19000101_000001" 45 CCID = "19000101_000001"
46+
47+ def fetch(self) -> list[JobPosting]:
48+ try:
49+ return super().fetch()
50+ except (requests.RequestException, ValueError) as exc:
51+ resp = getattr(exc, "response", None)
52+ if resp is not None and resp.status_code < 500:
53+ raise # 4xx franc : pas une panne liste, ne pas masquer
54+ jobs = self._fetch_known_jobs()
55+ if jobs is None:
56+ raise # API détail cassée aussi : vraie panne totale
57+ return jobs
58+
59+ def _known_ids(self) -> list[str]:
60+ """itemID (external_id) des offres actives de la source en base."""
61+ from .. import db
62+ con = db.connect()
63+ try:
64+ rows = con.execute(
65+ "SELECT external_id FROM jobs WHERE source=? AND active=1",
66+ (self.source_id,)).fetchall()
67+ finally:
68+ con.close()
69+ return [str(eid) for (eid,) in rows if eid]
70+
71+ def _fetch_known_jobs(self) -> list[JobPosting] | None:
72+ """Repli sans liste : chaque offre connue est revalidée via l'API
73+ détail (la réquisition complète, source de vérité de son existence).
74+ Aucune donnée inventée — tout vient de la réponse du moment."""
75+ out: list[JobPosting] = []
76+ errors = 0
77+ for iid in self._known_ids():
78+ try:
79+ r = self.get(f"{_API}/{iid}", params=self._params(),
80+ headers={"Accept": "application/json"}).json()
81+ except requests.HTTPError as exc:
82+ h = getattr(exc, "response", None)
83+ if h is not None and h.status_code == 404:
84+ continue # offre retirée chez l'employeur
85+ errors += 1
86+ continue
87+ except (requests.RequestException, ValueError):
88+ errors += 1 # non-JSON (maintenance) ou réseau
89+ continue
90+ if not (r or {}).get("requisitionTitle"):
91+ errors += 1 # réponse inattendue : ne pas conclure au retrait
92+ continue
93+ locations = self._locations(r)
94+ if not self._keep(locations):
95+ continue
96+ qc = next((l for l in locations
97+ if l["prov"].upper() == "QC"),
98+ locations[0] if locations else
99+ {"city": self.FORCE_CITY, "postal": "",
100+ "label": self.FORCE_CITY})
101+ job = JobPosting(
102+ source=self.source_id, external_id=iid,
103+ url=("https://workforcenow.adp.com/mascsr/default/mdf/"
104+ f"recruitment/recruitment.html?cid={self.CID}"
105+ f"&ccId={self.CCID}&lang={self.LANG}&jobId={iid}"),
106+ employer=self.EMPLOYER,
107+ title=r.get("requisitionTitle") or "",
108+ city=qc["city"], postal_code=qc["postal"],
109+ location_label=qc["label"],
110+ date_posted=r.get("postDate") or None,
111+ ats=self.ats,
112+ )
113+ pay = r.get("payGradeRange") or {}
114+ lo = (pay.get("minimumRate") or {}).get("amountValue")
115+ hi = (pay.get("maximumRate") or {}).get("amountValue")
116+ if lo:
117+ job.salary_min = float(lo)
118+ job.salary_max = float(hi) if hi else None
119+ job.salary_unit = "year" if float(lo) > 5000 else "hour"
120+ wl = (r.get("workLevelCode") or {}).get("shortName")
121+ if wl:
122+ job.details["employment_label"] = wl
123+ job.description = clean_html(r.get("requisitionDescription") or "")
124+ out.append(job)
125+ if not out and errors:
126+ return None # rien de validable : laisser le sync échouer
127+ return out
17 128
Menu

Theme
↑↓navigate ↵open escclose /⌘Kanywhere