uranusjr commented on code in PR #70951:
URL: https://github.com/apache/airflow/pull/70951#discussion_r3703590853
##########
airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py:
##########
@@ -529,6 +530,12 @@ def ti_update_state(
task_id=task_id,
)
+ # Release the task_instance row lock before running listener callbacks.
+ session.commit()
+
+ for callback in asset_callbacks:
Review Comment:
Registration callback failures cannot bubble here because the hook caller
unconditionally wraps them in a try-except (see
https://github.com/apache/airflow/pull/70951#discussion_r3701641837). So all
callbacks will always be run unless you kill the server process entirely.
--
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]
