jedcunningham commented on code in PR #45976:
URL: https://github.com/apache/airflow/pull/45976#discussion_r1927984399
##########
airflow/models/serialized_dag.py:
##########
@@ -201,8 +201,13 @@ def write_dag(
if serialized_dag_hash is not None and serialized_dag_hash ==
new_serialized_dag.dag_hash:
log.debug("Serialized DAG (%s) is unchanged. Skipping writing to
DB", dag.dag_id)
return False
+ dag_model = session.execute(
Review Comment:
It's probably better to pass the bundle_name and bundle_version down from
bulk_sync_to_db to here instead of querying it.
--
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]
