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

Head commit for run:
c5024469bbca7cd9abc8b22807f07b5598ef8017 / Stefan Wang 
<[email protected]>
AIP-96: add CHECKPOINTED state and AirflowTaskCheckpointed exception

Foundation for AIP-96 (Resumable Operators). Adds the vocabulary needed
to discuss the resumable-operator API shape against a real artifact:

- ``CHECKPOINTED`` task instance state (intermediate, lightyellow in UI),
  added to ``State.unfinished`` so downstream trigger rules treat it as
  "not yet finished".
- ``AirflowTaskCheckpointed`` exception with optional
  ``checkpoint_data`` payload, mirroring the ``AirflowRescheduleException``
  pattern (serializable, accepts a single domain payload).
- Worker handler in ``run()`` that catches the exception and reports the
  ``CHECKPOINTED`` state to the supervisor.
- Parametrized test ``TestTaskCheckpointed.test_run_returns_checkpointed_state``
  covering ``checkpoint_data`` shapes (``None``, dict, list).

Intentionally deferred to follow-ups so the API shape can be discussed
against a real artifact before committing to a single policy:

- ``checkpoint_data`` persistence and resume wiring.
- Scheduler treatment of ``CHECKPOINTED`` (auto-resume after delay vs.
  manual API-driven resume only).
- New listener hook ``on_task_instance_checkpointed`` and downstream
  observer integration.
- Trigger-rule semantics for downstream tasks of a ``CHECKPOINTED``
  upstream.

Marking draft so the design discussion can happen on the PR.

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

With regards,
GitHub Actions via GitBox


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

Reply via email to