ephraimbuddy opened a new pull request, #50825:
URL: https://github.com/apache/airflow/pull/50825
Enforces serialization of DAGs before creating DagRuns and TaskInstances.
The changes include:
- Making dag_version_id a required parameter in TaskInstance constructor
- Migrating the dag_version_id column in TaskInstance to be non-nullable
- Adding a check in _create_orm_dagrun to raise AirflowException if dag is
not serialized
- Updating tests to ensure DAGs are properly serialized before creating
DagRuns
This prevents running runs with missing serialized DAG versions.
--
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]
