ephraimbuddy edited a comment 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. -- 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]
