From 7ae3ad792e1792cf9db9eb376ad95b7a13a9d2d5 Mon Sep 17 00:00:00 2001 From: Niko Oliveira Date: Fri, 16 Jan 2026 11:35:27 -0800 Subject: [PATCH 1/2] Fix lambda executor max attempts config The documentation and even most of the code properly refers to the config as `max_invoke_attempts` but the config name itself (which was read from Airflow config/env) was using the wrong config name (`max_run_task_attempts` which comes from the ECS executor) --- providers/amazon/provider.yaml | 2 +- .../airflow/providers/amazon/aws/executors/aws_lambda/utils.py | 2 +- .../amazon/src/airflow/providers/amazon/get_provider_info.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/providers/amazon/provider.yaml b/providers/amazon/provider.yaml index 4c11640d27924..c8575f85b2c9f 100644 --- a/providers/amazon/provider.yaml +++ b/providers/amazon/provider.yaml @@ -1074,7 +1074,7 @@ config: type: boolean example: "True" default: "True" - max_run_task_attempts: + max_invoke_attempts: description: | The maximum number of times the Lambda Executor should attempt to start an Airflow task. version_added: "9.9.0" diff --git a/providers/amazon/src/airflow/providers/amazon/aws/executors/aws_lambda/utils.py b/providers/amazon/src/airflow/providers/amazon/aws/executors/aws_lambda/utils.py index 483b81508dbf5..370f070344f2b 100644 --- a/providers/amazon/src/airflow/providers/amazon/aws/executors/aws_lambda/utils.py +++ b/providers/amazon/src/airflow/providers/amazon/aws/executors/aws_lambda/utils.py @@ -59,7 +59,7 @@ class AllLambdaConfigKeys(InvokeLambdaKwargsConfigKeys): AWS_CONN_ID = "conn_id" CHECK_HEALTH_ON_STARTUP = "check_health_on_startup" - MAX_INVOKE_ATTEMPTS = "max_run_task_attempts" + MAX_INVOKE_ATTEMPTS = "max_invoke_attempts" REGION_NAME = "region_name" QUEUE_URL = "queue_url" DLQ_URL = "dead_letter_queue_url" diff --git a/providers/amazon/src/airflow/providers/amazon/get_provider_info.py b/providers/amazon/src/airflow/providers/amazon/get_provider_info.py index a85c6668b945f..cf6ac17ad6561 100644 --- a/providers/amazon/src/airflow/providers/amazon/get_provider_info.py +++ b/providers/amazon/src/airflow/providers/amazon/get_provider_info.py @@ -1207,7 +1207,7 @@ def get_provider_info(): "example": "True", "default": "True", }, - "max_run_task_attempts": { + "max_invoke_attempts": { "description": "The maximum number of times the Lambda Executor should attempt to start an Airflow task.\n", "version_added": "9.9.0", "type": "integer", From 43e03074dc64e55ceabbe7bc971970c931e7c056 Mon Sep 17 00:00:00 2001 From: Niko Oliveira Date: Fri, 16 Jan 2026 11:59:03 -0800 Subject: [PATCH 2/2] Update changelog for the breaking change --- providers/amazon/docs/changelog.rst | 1 + 1 file changed, 1 insertion(+) diff --git a/providers/amazon/docs/changelog.rst b/providers/amazon/docs/changelog.rst index ac39007d20cc2..a600f7951e69e 100644 --- a/providers/amazon/docs/changelog.rst +++ b/providers/amazon/docs/changelog.rst @@ -25,6 +25,7 @@ Changelog --------- +* ``Rename ''max_run_task_attempts'' to ''max_invoke_attempts'' in AWS Lambda Executor (#60666)`` 9.20.0 ......