ChickenBenny commented on code in PR #76359:
URL: https://github.com/apache/airflow/pull/76359#discussion_r4549109651
##########
task-sdk/src/airflow/sdk/coordinators/_subprocess.py:
##########
@@ -564,8 +562,18 @@ def _prepare_ti_context(self, ti: TaskInstance,
ti_context: TIRunContext) -> TIR
backend's storage.
If an XCom cannot be deleted, this try fails and the task does not run.
+
+ Also fills in the worker's default ``execution_timeout`` when the task
sets none.
"""
- self._execution_timeout_seconds = ti_context.execution_timeout
+ # A task that sets no execution_timeout gets the worker's default, as
a Python task does when the
+ # worker parses its Dag. A zero means no timeout, so it does not fall
back.
+ execution_timeout = ti_context.execution_timeout
Review Comment:
Fix with d97f3926608d97aebc3fa3af529d3850c49535b7
--
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]
