ephraimbuddy commented on issue #16227: URL: https://github.com/apache/airflow/issues/16227#issuecomment-854327049
@Prasnal @millin I have been able to reproduce this only when I have dagrun_timeout set and the dag_run times out. Let me know if you also set dagrun_timeout in your dags. My case is caused by these lines: https://github.com/apache/airflow/blob/5e0992688c0308afd6436c8fd9a892d3af94ced6/airflow/jobs/scheduler_job.py#L1730-L1739 When the skipped state is set, the local task job sees this as being externally set and terminates the task runner. Normally tasks update DagRuns but here we are using DagRun to update tasks( that's what I think... :) ) -- 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. For queries about this service, please contact Infrastructure at: [email protected]
