The GitHub Actions job "Tests (AMD)" on airflow.git/fix-mapped-retry-policy-serialization has succeeded. Run started by GitHub user vatsrahul1001 (triggered by vatsrahul1001).
Head commit for run: 50d575b7a58a586633dd93e2fdeaeda2214d6773 / Rahul Vats <[email protected]> Fix non-deterministic serialization of mapped task retry_policy A mapped operator keeps retry_policy in partial_kwargs, but the mapped-operator serializer has no serializer for a RetryPolicy, so it fell back to str(obj) -- embedding the object's per-process memory address. That made the serialized DAG non-deterministic: dag_hash changed on every parse, defeating write_dag's "unchanged" check and creating a new DagVersion on nearly every DAG-processor re-serialization (even for idle, never-run DAGs), polluting version history and bloating the metadata DB. Non-mapped operators already avoid this by excluding the object and storing only a has_retry_policy flag; this makes the mapped path do the same. Runtime is unaffected -- the worker re-parses the DAG source for the live policy. Report URL: https://github.com/apache/airflow/actions/runs/28582526037 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
