ChickenBenny commented on code in PR #75387: URL: https://github.com/apache/airflow/pull/75387#discussion_r4412835010
########## airflow-core/docs/core-concepts/tasks.rst: ########## @@ -145,6 +145,15 @@ if the task has not stopped within ``[core] killed_task_cleanup_time`` seconds a (for example because it is blocked in native code), the supervisor sends it SIGTERM, and SIGKILL after the same period again. Tasks run by a language SDK do not raise ``AirflowTaskTimeout`` and are stopped only this way. +A task that does not set ``execution_timeout`` itself gets ``[core] default_task_execution_timeout``, which is read in +different places depending on how the task runs: + +- A Python task reads it on the worker, which parses the Dag file again before running the task. +- A task run by a language SDK reads it where the Dag processor runs, when the Dag is parsed and serialized. + +Set ``[core] default_task_execution_timeout`` to the same value on the Dag processor and the workers, so both kinds +of task get the same default. + Review Comment: Removed in 6fd3f103f2 -- 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]
