The GitHub Actions job "Tests (AMD)" on 
airflow.git/triggerdagrun-owns-execution has failed.
Run started by GitHub user 1fanwang (triggered by 1fanwang).

Head commit for run:
ea1d794b7cf797a09d556f7510fda00cfb6c7c31 / 1fanwang <[email protected]>
Make TriggerDagRunOperator own its synchronous execution and add durable 
reconnect

On Airflow 3, TriggerDagRunOperator.execute() raised DagRunTriggerException and 
the task runner did the trigger and the wait loop, so the synchronous 
wait-and-reconnect contract was duplicated between the operator and the runner 
and could drift. With the new ti.trigger_dag_run() accessor the operator does 
the submit and poll itself and reuses ResumableJobMixin directly, keeping that 
contract in one place. The opt-in durable flag persists the triggered run id 
before polling so a worker crash mid-wait reconnects to the in-flight run on 
retry instead of triggering a duplicate. Deferrable still needs the triggerer 
handoff, so it keeps the exception path; Airflow < 3.3 and Airflow 2 are 
unchanged.

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

With regards,
GitHub Actions via GitBox


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

Reply via email to