uranusjr commented on code in PR #75387:
URL: https://github.com/apache/airflow/pull/75387#discussion_r4421637288
##########
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/taskinstance.py:
##########
@@ -558,10 +558,11 @@ class TIRunContext(BaseModel):
execution_timeout: float | None = None
"""
- The ``execution_timeout`` in seconds of a task a language SDK runs, from
its serialized Dag.
+ The ``execution_timeout`` in seconds set on a task a language SDK runs,
from its serialized Dag.
- The supervisor enforces the timeout with this value. A Python task runs
its own timer in the task
- runner instead, and gets no value here. ``None`` when no timeout is set.
+ Unset when the task sets none. Zero means no timeout and a negative value
has already elapsed, as
+ for a Python task. A Python task runs its own timer in the task runner
instead, and gets no value
+ here.
Review Comment:
This should be in the generated schema’s `description` field since the
contract needs to be followed by all SDKs, not just Python.
--
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]
