eladkal commented on code in PR #41260:
URL: https://github.com/apache/airflow/pull/41260#discussion_r1704559495
##########
airflow/models/taskinstance.py:
##########
@@ -3892,9 +3892,12 @@ def schedule_downstream_tasks(self, session: Session =
NEW_SESSION, max_tis_per_
:meta: private
"""
- return TaskInstance._schedule_downstream_tasks(
- ti=self, session=session, max_tis_per_query=max_tis_per_query
- )
+ try:
+ return TaskInstance._schedule_downstream_tasks(
+ ti=self, session=session, max_tis_per_query=max_tis_per_query
+ )
+ except Exception:
+ self.log.exception("Error scheduling downstream tasks. Skipping
it")
Review Comment:
> I believe it is quite good to explicitly tell "something happen" - and
while yes - we do not know exactly what the user can do to avoid it, it will at
least give the user a chance to understand and fix it (or maybe submit an issue
/ discussion here and get help.
Then lets say this explicitly in the message. I think we can just say that
it can be caused by several reasons and link to the relevant discussion.
--
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]
