The GitHub Actions job "Tests (AMD)" on airflow.git/fix/68941-dagparam-serialization-in-partial has failed. Run started by GitHub user gingeekrishna (triggered by potiuk).
Head commit for run: 74b1a314d2c9ab7cb0b1dde9e7e8327864e42b3a / Radhakrishnan Pachyappan <[email protected]> fix(serialization): DagParam in partial() of mapped task serializes stably Fixes #68941 When DagParam is used as a kwarg in partial() of a dynamically mapped task, BaseSerialization.serialize() had no branch for DagParam and fell through to str(var), embedding a non-deterministic memory address in partial_kwargs. This caused a new DAG version to be written on every scheduler parse cycle. Add DAT.DAG_PARAM to the type enum and handle DagParam in both serialize() and deserialize(). During deserialization a _DagParamRef placeholder (similar to _XComRef for XComArg) stores the stable dag_id/name/default triple until set_task_dag_references() can attach the live DAG reference once the DAG is fully hydrated. Four regression tests cover: stable serialization (no memory address), full round-trip (DagParam reconstructed with correct dag reference), version stability (two serializations of same DAG are identical), and NOTSET default preservation. Report URL: https://github.com/apache/airflow/actions/runs/28299571649 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
