This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-1-test by this push:
new 7d4a80d8bda Fix typo in config key: missing_dag_retires ->
missing_dag_retries (#62087)
7d4a80d8bda is described below
commit 7d4a80d8bda84bc5a0231e663b329076977105e0
Author: Kaxil Naik <[email protected]>
AuthorDate: Tue Feb 17 18:55:57 2026 +0000
Fix typo in config key: missing_dag_retires -> missing_dag_retries (#62087)
The `[workers] missing_dag_retires` config option introduced in 3.1.7
has a typo ("retires" instead of "retries"). Rename it to
`missing_dag_retries` and add a deprecated_options entry so existing
users who set the old key name are not broken.
(cherry picked from commit a6e24198b3434050b7cf63d9a21962842d1a82d9)
---
airflow-core/src/airflow/config_templates/config.yml | 2 +-
airflow-core/src/airflow/configuration.py | 1 +
task-sdk/src/airflow/sdk/execution_time/task_runner.py | 6 +++---
task-sdk/tests/task_sdk/execution_time/test_task_runner.py | 2 +-
4 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/airflow-core/src/airflow/config_templates/config.yml
b/airflow-core/src/airflow/config_templates/config.yml
index c9ab850a62b..62edde02e2a 100644
--- a/airflow-core/src/airflow/config_templates/config.yml
+++ b/airflow-core/src/airflow/config_templates/config.yml
@@ -1610,7 +1610,7 @@ workers:
type: float
example: ~
default: "60.0"
- missing_dag_retires:
+ missing_dag_retries:
description: |
Maximum number of times a task will be rescheduled if the worker fails
to
load the Dag or task definition during startup.
diff --git a/airflow-core/src/airflow/configuration.py
b/airflow-core/src/airflow/configuration.py
index fd48364cd6f..216804fae17 100644
--- a/airflow-core/src/airflow/configuration.py
+++ b/airflow-core/src/airflow/configuration.py
@@ -376,6 +376,7 @@ class AirflowConfigParser(ConfigParser):
("api", "require_confirmation_dag_change"): ("webserver",
"require_confirmation_dag_change", "3.1.0"),
("api", "instance_name"): ("webserver", "instance_name", "3.1.0"),
("api", "log_config"): ("api", "access_logfile", "3.1.0"),
+ ("workers", "missing_dag_retries"): ("workers", "missing_dag_retires",
"3.1.8"),
}
# A mapping of new section -> (old section, since_version).
diff --git a/task-sdk/src/airflow/sdk/execution_time/task_runner.py
b/task-sdk/src/airflow/sdk/execution_time/task_runner.py
index 3fde5b628d7..a9a3b28cfc9 100644
--- a/task-sdk/src/airflow/sdk/execution_time/task_runner.py
+++ b/task-sdk/src/airflow/sdk/execution_time/task_runner.py
@@ -619,11 +619,11 @@ def _maybe_reschedule_startup_failure(
This does not count as a retry. If the reschedule limit is exceeded, this
function
returns and the caller should fail the task.
"""
- missing_dag_retires = conf.getint("workers", "missing_dag_retires",
fallback=3)
+ missing_dag_retries = conf.getint("workers", "missing_dag_retries",
fallback=3)
missing_dag_retry_delay = conf.getint("workers",
"missing_dag_retry_delay", fallback=60)
reschedule_count = int(getattr(ti_context, "task_reschedule_count", 0) or
0)
- if missing_dag_retires > 0 and reschedule_count < missing_dag_retires:
+ if missing_dag_retries > 0 and reschedule_count < missing_dag_retries:
raise AirflowRescheduleException(
reschedule_date=datetime.now(tz=timezone.utc) +
timedelta(seconds=missing_dag_retry_delay)
)
@@ -631,7 +631,7 @@ def _maybe_reschedule_startup_failure(
log.error(
"Startup reschedule limit exceeded",
reschedule_count=reschedule_count,
- max_reschedules=missing_dag_retires,
+ max_reschedules=missing_dag_retries,
)
diff --git a/task-sdk/tests/task_sdk/execution_time/test_task_runner.py
b/task-sdk/tests/task_sdk/execution_time/test_task_runner.py
index 84fecdb2eba..7df042ca64f 100644
--- a/task-sdk/tests/task_sdk/execution_time/test_task_runner.py
+++ b/task-sdk/tests/task_sdk/execution_time/test_task_runner.py
@@ -321,7 +321,7 @@ def
test_parse_not_found_does_not_reschedule_when_max_attempts_reached(test_dags
with (
conf_vars(
{
- ("workers", "missing_dag_retires"): "3",
+ ("workers", "missing_dag_retries"): "3",
("workers", "missing_dag_retry_delay"): "60",
}
),
