The GitHub Actions job "Check newsfragment PR number" on airflow.git/1fanwang/aip96-resumable-operator-demo has failed. Run started by GitHub user 1fanwang (triggered by 1fanwang).
Head commit for run: 48dcc5e957402ae850848e5a4dfbb5dfea9728e5 / 1fanwang <[email protected]> [demo] AIP-96 resumable operator example Self-contained reference operator demonstrating the v1 integration pattern: operator submits an external job, persists the external job ID via AIP-103 task_state, and on worker disruption raises AirflowTaskCheckpointed so the next attempt reconnects rather than restarts. The 'external job' is simulated in-process so the demo runs without external infrastructure. A real operator (Databricks, EMR, Spark-on-K8s) follows the same shape but calls actual APIs in submit/poll. To exercise the resume flow end-to-end: 1. Trigger example_resumable_operator DAG. 2. While the task is RUNNING, send SIGTERM to its worker process. Operator catches it, raises AirflowTaskCheckpointed, task transitions to CHECKPOINTED. 3. Scheduler dispatches next attempt at next tick. Operator reads prior external_job_id from task_state and resumes polling without resubmitting. Marked as draft / for-discussion alongside AIP-96 v2. Report URL: https://github.com/apache/airflow/actions/runs/25418399428 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
