mhenc commented on code in PR #35527:
URL: https://github.com/apache/airflow/pull/35527#discussion_r1388029938
##########
airflow/models/taskinstance.py:
##########
@@ -2025,6 +2060,7 @@ def check_and_change_state_before_execution(
ignore_ti_state: bool = False,
mark_success: bool = False,
test_mode: bool = False,
+ hostname: str = "",
Review Comment:
Thanks. Done.
##########
airflow/models/taskinstance.py:
##########
@@ -3196,19 +3269,30 @@ def schedule_downstream_tasks(self, session: Session =
NEW_SESSION, max_tis_per_
schedulable_ti.task =
task.dag.get_task(schedulable_ti.task_id)
num = dag_run.schedule_tis(schedulable_tis, session=session,
max_tis_per_query=max_tis_per_query)
- self.log.info("%d downstream tasks scheduled from follow-on
schedule check", num)
+ ti.log.info("%d downstream tasks scheduled from follow-on schedule
check", num)
Review Comment:
Good idea
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
