The GitHub Actions job "Check newsfragment PR number" on 
airflow.git/1fanwang/aip96-supervisor-wiring has failed.
Run started by GitHub user 1fanwang (triggered by 1fanwang).

Head commit for run:
89c2edb81d94e8e1be786adad63eee0d86c79bf9 / 1fanwang <[email protected]>
AIP-96: wire CHECKPOINTED through supervisor → API server → DB

The CHECKPOINTED state introduced in #66402 reached the message boundary
but the DB row never transitioned because the supervisor's
STATES_SENT_DIRECTLY list and the API server's state-update endpoint
both rejected it. This PR closes the wiring:

  - Supervisor: CHECKPOINTED is added to STATES_SENT_DIRECTLY so it
    skips the terminal-state finish() path. The TaskState handler
    now calls a new client.task_instances.checkpoint() method.
  - Client: new checkpoint() method PATCHes /task-instances/{id}/state
    with TITargetStatePayload(state=CHECKPOINTED).
  - API server: a new branch in the state-update handler accepts
    TITargetStatePayload (the discriminated-union 'other' tag) and
    updates the row to checkpointed without additional bookkeeping.

Verified end-to-end on airflow standalone — a DAG that raises
AirflowTaskCheckpointed now lands the DB row at state='checkpointed'
(was 'failed' before).

checkpoint_data persistence is intentionally not added; the right shape
(XCom-backed, new TaskInstance JSON column, separate metadata table) is
the open AIP-96 question this PR deliberately leaves to the AIP discussion.

Report URL: https://github.com/apache/airflow/actions/runs/25400872728

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to