Subham-KRLX opened a new pull request, #65579:
URL: https://github.com/apache/airflow/pull/65579
This PR resolves a high priority regression where the OpenLineage listener
crashes with a DetachedInstanceError during on_dag_run_success or
on_dag_run_failed events.
The Problem: In Airflow 3.2+ the DagRun model added a note association proxy
the OpenLineage DagRunInfo class attempts to access this attribute during event
serialization. Since the listener often processes DagRun instances that are
detached from a SQLAlchemy session this access triggers a lazy-load that fails
and crashes the listener, blocking system tests (e.g., BigQuery).
The Fix: Introduced a safe_getattr utility in the OpenLineage provider that
catches DetachedInstanceError and returns None as a fallback. Applied this to
both note and deadlines fields in DagRunInfo to ensure the listener remains
stable even when working with detached objects.
closes: #65577
Was generative AI tooling used to co-author this PR?
Yes — Claude(For pr description)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
