def getCNCEData(**context):
    ti = context["ti"]
    token = ti.xcom_pull(key="token")

    response = requests.get(
    url=f"{dRoW_api_end_url}/api/module/document-export/airflow/workflow/637c7d22b38f8ca02f5c49ab?export_type=0",
    headers={
        "x-access-token": f"Bearer {token}",
        "ICWPxAccessKey": "5WSD21ICWP_[1AG:4UdI){n=b~"
        }
    )

    cnceData = response.json()
    print(f"check cnce data: {cnceData}")

    today = datetime.now(timezone.utc)

    rows = []
    for item in cnceData:
        d = (item.get("data") or {})
        event_no = (d.get("NEC Event No.") or "").strip()
        doc_type = (d.get("NEC Doc Type") or "").strip()
        doc_date_raw = d.get("Doc Date")  # boss wants this
        receive_date_raw = d.get("Receive Date")

        # pick a best-effort "doc_datetime"
        doc_dt = parse_any_dt(doc_date_raw) or parse_any_dt(receive_date_raw)

        if not event_no or not doc_type or not doc_dt:
            continue

        rows.append({
            "event_no": event_no,
            "doc_type": doc_type.strip().upper(),
            "doc_dt": doc_dt,
        })

    # 2) group by event_no and find latest doc
    latest_by_event = {}
    for r in rows:
        key = r["event_no"]
        cur = latest_by_event.get(key)
        if (cur is None) or (r["doc_dt"] > cur["doc_dt"]):
            latest_by_event[key] = r

    # 3) unreplied NCE = latest doc is NCE
    unreplied_nce = []
    for event_no, latest in latest_by_event.items():
        if latest["doc_type"].startswith("NCE"):
            unreplied_nce.append(latest)  # keep latest doc row (its doc_dt is the NCE date)

    # 4) KPI rules (calendar months)
    kpi5_cutoff = today - relativedelta(months=3)
    kpi6_cutoff = today - relativedelta(months=6)

    kpi5 = sum(1 for r in unreplied_nce if r["doc_dt"] < kpi5_cutoff)
    kpi6 = sum(1 for r in unreplied_nce if r["doc_dt"] < kpi6_cutoff)

    print("unreplied NCE total:", len(unreplied_nce))
    print("KPI 5:", kpi5)
    print("KPI 6:", kpi6)

    # push into XCom so writeKpiToPostgres can store
    ti.xcom_push(key="kpi5", value=int(kpi5))
    ti.xcom_push(key="kpi6", value=int(kpi6))

    return {"kpi5": int(kpi5), "kpi6": int(kpi6)}