The GitHub Actions job "Tests (AMD)" on 
airflow.git/feature/mutation-hook-dag-run has failed.
Run started by GitHub user dheerajturaga (triggered by dheerajturaga).

Head commit for run:
17b28cc600643b6d2e939f38db926d33a7630f93 / Dheeraj Turaga 
<[email protected]>
Store resolved param defaults in dag_run.conf for runs with no explicit conf

When a DAG run is created without an explicit conf dict (all scheduled runs,
and manual triggers that omit config), dag_run.conf was stored as None even
though the param defaults had already been merged and validated. Any runtime
consumer reading dag_run.conf -- tasks using {{ dag_run.conf }}, the
task_instance_mutation_hook reading dag_run.conf for queue routing, sensors
checking conf values -- silently got None for scheduled runs.

The fix is one line: pass the already-computed copied_params dict as conf when
the caller supplied none. copied_params is the result of deep_merge(conf) and
validate(), so no extra work is done -- the resolved value is just preserved
instead of discarded.

Manual/triggered runs that supply an explicit conf are unaffected: their
caller-supplied dict is stored as before.

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

With regards,
GitHub Actions via GitBox


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

Reply via email to