karenbraganz commented on issue #58536: URL: https://github.com/apache/airflow/issues/58536#issuecomment-3559368087
I have also been able to reproduce this issue on Airflow 2.11. I agree with Chris' analysis on the root cause. - The `set_state` method should be called for the unfinished task instances as well instead of directly setting the state in the DBso that the end_date is set. - The task instance duration should also be set. - Additionally, callbacks should be run because the task instance could have an on_skipped_callback. - This code only skips the running task instances. Downstream task instances remain in the None state. Why aren't all task instances skipped? -- 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]
