ephraimbuddy commented on a change in pull request #21413:
URL: https://github.com/apache/airflow/pull/21413#discussion_r808711668
##########
File path: airflow/models/dagrun.py
##########
@@ -609,6 +609,7 @@ def update_state(
self.data_interval_end,
self.dag_hash,
)
+ session.flush()
Review comment:
That was my initial thought but I don't know if there would be a
regression when added there since it would apply to running `dagruns` as well.
It use to have a `commit` down there, after `merge` but was removed here:
https://github.com/apache/airflow/commit/73b9163a8f55ce3d5bf6aec0a558952c27dd1b55#diff-649fbbf224bab54417f03338c27d0fdb3c3336e53a522a13dfd9806c99f63137L377
cc: @ashb
--
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]
