amoghrajesh commented on issue #55753: URL: https://github.com/apache/airflow/issues/55753#issuecomment-3302190652
Under a normal operation (not killed my system: OOM or whatever), the API server sends in the decision if a task can retry or not with the run context response: https://github.com/apache/airflow/blob/main/airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py#L270, this is later tried on by the task runner itself. So -- in short, api server decides it and the task sdk enforces it. > I know a task can say "fail and don't retry" but isn't that a different API endpoint we hit? Nope, it is part of the same TI state update endpoint. We either send failed / up_for_retry to the API server through TI update API and it marks it as such. -- 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]
