You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ch...@apache.org on 2026/04/29 14:29:05 UTC
(airflow) branch main updated: refactor: DAG to Dag in comment for api_fastapi (#66099)
This is an automated email from the ASF dual-hosted git repository.
choo121600 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 8a3aa3813e2 refactor: DAG to Dag in comment for api_fastapi (#66099)
8a3aa3813e2 is described below
commit 8a3aa3813e2a114f5380432debb46a2aefd05c23
Author: hojeong park <pa...@gmail.com>
AuthorDate: Wed Apr 29 23:28:57 2026 +0900
refactor: DAG to Dag in comment for api_fastapi (#66099)
---
.../api_fastapi/auth/managers/base_auth_manager.py | 16 ++++++++--------
.../auth/managers/models/resource_details.py | 4 ++--
.../auth/managers/simple/simple_auth_manager.py | 2 +-
airflow-core/src/airflow/api_fastapi/common/dagbag.py | 6 +++---
airflow-core/src/airflow/api_fastapi/common/db/dags.py | 8 ++++----
.../src/airflow/api_fastapi/common/parameters.py | 4 ++--
.../api_fastapi/core_api/openapi/_private_ui.yaml | 10 +++++-----
.../core_api/openapi/v2-rest-api-generated.yaml | 12 ++++++------
.../api_fastapi/core_api/routes/public/dag_versions.py | 4 ++--
.../api_fastapi/core_api/routes/public/dag_warning.py | 2 +-
.../airflow/api_fastapi/core_api/routes/ui/calendar.py | 2 +-
.../src/airflow/api_fastapi/core_api/routes/ui/dags.py | 6 +++---
.../api_fastapi/core_api/routes/ui/dashboard.py | 2 +-
.../api_fastapi/core_api/routes/ui/deadlines.py | 6 +++---
.../src/airflow/api_fastapi/core_api/routes/ui/grid.py | 12 ++++++------
.../api_fastapi/core_api/routes/ui/structure.py | 4 ++--
.../src/airflow/api_fastapi/execution_api/AGENTS.md | 4 ++--
.../airflow/ui/openapi-gen/queries/ensureQueryData.ts | 18 +++++++++---------
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 18 +++++++++---------
.../src/airflow/ui/openapi-gen/queries/queries.ts | 18 +++++++++---------
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 18 +++++++++---------
.../airflow/ui/openapi-gen/requests/services.gen.ts | 18 +++++++++---------
.../src/airflow/ui/openapi-gen/requests/types.gen.ts | 2 +-
23 files changed, 98 insertions(+), 98 deletions(-)
diff --git a/airflow-core/src/airflow/api_fastapi/auth/managers/base_auth_manager.py b/airflow-core/src/airflow/api_fastapi/auth/managers/base_auth_manager.py
index 303d1971b33..4bd49cccf47 100644
--- a/airflow-core/src/airflow/api_fastapi/auth/managers/base_auth_manager.py
+++ b/airflow-core/src/airflow/api_fastapi/auth/managers/base_auth_manager.py
@@ -247,13 +247,13 @@ class BaseAuthManager(Generic[T], LoggingMixin, metaclass=ABCMeta):
details: DagDetails | None = None,
) -> bool:
"""
- Return whether the user is authorized to perform a given action on a DAG.
+ Return whether the user is authorized to perform a given action on a Dag.
:param method: the method to perform
:param user: the user to performing the action
- :param access_entity: the kind of DAG information the authorization request is about.
- If not provided, the authorization request is about the DAG itself
- :param details: optional details about the DAG
+ :param access_entity: the kind of Dag information the authorization request is about.
+ If not provided, the authorization request is about the Dag itself
+ :param details: optional details about the Dag
"""
@abstractmethod
@@ -564,7 +564,7 @@ class BaseAuthManager(Generic[T], LoggingMixin, metaclass=ABCMeta):
session: Session = NEW_SESSION,
) -> set[str]:
"""
- Get DAGs the user has access to.
+ Get Dags the user has access to.
:param user: the user
:param method: the method to filter on
@@ -604,13 +604,13 @@ class BaseAuthManager(Generic[T], LoggingMixin, metaclass=ABCMeta):
team_name: str | None = None,
) -> set[str]:
"""
- Filter DAGs the user has access to.
+ Filter Dags the user has access to.
- By default, check individually if the user has permissions to access the DAG.
+ By default, check individually if the user has permissions to access the Dag.
Can lead to some poor performance. It is recommended to override this method in the auth manager
implementation to provide a more efficient implementation.
- :param dag_ids: the set of DAG ids
+ :param dag_ids: the set of Dag ids
:param user: the user
:param method: the method to filter on
:param team_name: the name of the team associated to the Dags if Airflow environment runs in
diff --git a/airflow-core/src/airflow/api_fastapi/auth/managers/models/resource_details.py b/airflow-core/src/airflow/api_fastapi/auth/managers/models/resource_details.py
index 4ff380d2aed..41775d8043e 100644
--- a/airflow-core/src/airflow/api_fastapi/auth/managers/models/resource_details.py
+++ b/airflow-core/src/airflow/api_fastapi/auth/managers/models/resource_details.py
@@ -40,7 +40,7 @@ class ConnectionDetails:
@dataclass
class DagDetails:
- """Represents the details of a DAG."""
+ """Represents the details of a Dag."""
id: str | None = None
team_name: str | None = None
@@ -109,7 +109,7 @@ class AccessView(Enum):
class DagAccessEntity(Enum):
- """Enum of DAG entities the user tries to access."""
+ """Enum of Dag entities the user tries to access."""
AUDIT_LOG = "AUDIT_LOG"
CODE = "CODE"
diff --git a/airflow-core/src/airflow/api_fastapi/auth/managers/simple/simple_auth_manager.py b/airflow-core/src/airflow/api_fastapi/auth/managers/simple/simple_auth_manager.py
index 2b13f10eb9b..645b9c3f7d7 100644
--- a/airflow-core/src/airflow/api_fastapi/auth/managers/simple/simple_auth_manager.py
+++ b/airflow-core/src/airflow/api_fastapi/auth/managers/simple/simple_auth_manager.py
@@ -72,7 +72,7 @@ class SimpleAuthManagerRole(namedtuple("SimpleAuthManagerRole", "name order"), E
# VIEWER role gives all read-only permissions
VIEWER = "VIEWER", 0
- # USER role gives viewer role permissions + access to DAGs
+ # USER role gives viewer role permissions + access to Dags
USER = "USER", 1
# OP role gives user role permissions + access to connections, config, pools, variables
diff --git a/airflow-core/src/airflow/api_fastapi/common/dagbag.py b/airflow-core/src/airflow/api_fastapi/common/dagbag.py
index 83350bfa379..af3a05d98af 100644
--- a/airflow-core/src/airflow/api_fastapi/common/dagbag.py
+++ b/airflow-core/src/airflow/api_fastapi/common/dagbag.py
@@ -92,11 +92,11 @@ def get_dag_for_run_or_latest_version(
dag_bag: DBDagBag, dag_run: DagRun | None, dag_id: str | None, session: Session
) -> SerializedDAG:
"""
- Retrieve the serialized DAG for a specific run, or the latest version if no run is given.
+ Retrieve the serialized Dag for a specific run, or the latest version if no run is given.
- When a dag_run is provided, we prefer the exact DAG version the run was created with
+ When a dag_run is provided, we prefer the exact Dag version the run was created with
(``created_dag_version_id``) so that task group lookups, operator metadata, etc. match
- the DAG structure at the time of the run.
+ the Dag structure at the time of the run.
This is necessary because ``get_dag_for_run`` delegates to ``_version_from_dag_run``
which, for unversioned bundles (e.g. ``LocalDagBundle``), falls back to the *latest*
diff --git a/airflow-core/src/airflow/api_fastapi/common/db/dags.py b/airflow-core/src/airflow/api_fastapi/common/db/dags.py
index f1104f839e3..41c219d8208 100644
--- a/airflow-core/src/airflow/api_fastapi/common/db/dags.py
+++ b/airflow-core/src/airflow/api_fastapi/common/db/dags.py
@@ -37,13 +37,13 @@ def generate_dag_with_latest_run_query(
max_run_filters: list[BaseParam], order_by: SortParam, *, dag_ids: set[str] | None = None
) -> Select:
"""
- Generate a query to fetch DAGs with their latest run.
+ Generate a query to fetch Dags with their latest run.
:param max_run_filters: List of filters to apply to the latest run
:param order_by: Sort parameter for ordering results
- :param dag_ids: Optional set of DAG IDs to limit the query to. When provided, both the main
- DAG query and the subquery for finding the latest runs will be filtered to
- only these DAG IDs, improving performance when users have limited DAG access.
+ :param dag_ids: Optional set of Dag IDs to limit the query to. When provided, both the main
+ Dag query and the subquery for finding the latest runs will be filtered to
+ only these Dag IDs, improving performance when users have limited Dag access.
:return: SQLAlchemy Select statement
"""
query = select(DagModel).options(selectinload(DagModel.tags))
diff --git a/airflow-core/src/airflow/api_fastapi/common/parameters.py b/airflow-core/src/airflow/api_fastapi/common/parameters.py
index 73f5b995f2b..a93ec040e1c 100644
--- a/airflow-core/src/airflow/api_fastapi/common/parameters.py
+++ b/airflow-core/src/airflow/api_fastapi/common/parameters.py
@@ -354,7 +354,7 @@ class _TaskDisplayNamePrefixPatternParam(_PrefixPatternParam):
"Prefix match on task display name: optional ``_task_display_property_value`` else "
"``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to "
"``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` "
- "(or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. "
+ "(or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. "
"Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the "
"term are stripped before matching so the range scan stays index-compatible under "
"locale-aware collations."
@@ -1056,7 +1056,7 @@ QueryAssetDependencyFilter = Annotated[_AssetDependencyFilter, Depends(_AssetDep
class _ConsumingAssetFilter(BaseParam[str | None]):
- """Filter DAG runs by consuming asset (name or URI)."""
+ """Filter Dag runs by consuming asset (name or URI)."""
def to_orm(self, select: Select) -> Select:
if not self.value and self.skip_none:
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml b/airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml
index 364ecd38f95..f8d52e6e5da 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml
+++ b/airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml
@@ -633,7 +633,7 @@ paths:
tags:
- Dashboard
summary: Dag Stats
- description: Return basic DAG stats with counts of DAGs in various states.
+ description: Return basic Dag stats with counts of Dags in various states.
operationId: dag_stats
responses:
'200':
@@ -650,13 +650,13 @@ paths:
tags:
- Deadlines
summary: Get Deadlines
- description: 'Get deadlines for a DAG run.
+ description: 'Get deadlines for a Dag run.
This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve
Deadlines for all
- DAGs and DAG runs.'
+ Dags and Dag runs.'
operationId: get_deadlines
security:
- OAuth2PasswordBearer: []
@@ -816,7 +816,7 @@ paths:
tags:
- Deadlines
summary: Get Dag Deadline Alerts
- description: Get all deadline alerts defined on a DAG.
+ description: Get all deadline alerts defined on a Dag.
operationId: get_dag_deadline_alerts
security:
- OAuth2PasswordBearer: []
@@ -1526,7 +1526,7 @@ paths:
tags:
- Calendar
summary: Get Calendar
- description: Get calendar data for a DAG including historical and planned DAG
+ description: Get calendar data for a Dag including historical and planned Dag
runs.
operationId: get_calendar
security:
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml b/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
index cbe2229cfd9..851d5647fdf 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
+++ b/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
@@ -3240,7 +3240,7 @@ paths:
tags:
- DagWarning
summary: List Dag Warnings
- description: Get a list of DAG warnings.
+ description: Get a list of Dag warnings.
operationId: list_dag_warnings
security:
- OAuth2PasswordBearer: []
@@ -7688,7 +7688,7 @@ paths:
description: 'Prefix match on task display name: optional ``_task_display_property_value``
else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly
alternative to ``task_display_name_pattern``. On large databases, combine
- with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id,
+ with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id,
task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all.
Trailing non-alphanumeric characters in the term are stripped before matching
so the range scan stays index-compatible under locale-aware collations.'
@@ -7696,7 +7696,7 @@ paths:
description: 'Prefix match on task display name: optional ``_task_display_property_value``
else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly
alternative to ``task_display_name_pattern``. On large databases, combine
- with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id,
+ with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id,
task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all.
Trailing non-alphanumeric characters in the term are stripped before matching
so the range scan stays index-compatible under locale-aware collations.'
@@ -9457,11 +9457,11 @@ paths:
tags:
- DagVersion
summary: Get Dag Versions
- description: 'Get all DAG Versions.
+ description: 'Get all Dag Versions.
- This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions
- for all DAGs.'
+ This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions
+ for all Dags.'
operationId: get_dag_versions
security:
- OAuth2PasswordBearer: []
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_versions.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_versions.py
index bbb99441f81..d370e113b0a 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_versions.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_versions.py
@@ -108,9 +108,9 @@ def get_dag_versions(
readable_dag_versions_filter: ReadableDagVersionsFilterDep,
) -> DAGVersionCollectionResponse:
"""
- Get all DAG Versions.
+ Get all Dag Versions.
- This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions for all DAGs.
+ This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions for all Dags.
"""
query = select(DagVersion).options(joinedload(DagVersion.dag_model), joinedload(DagVersion.bundle))
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_warning.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_warning.py
index 3884a165e99..c1a652c370f 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_warning.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_warning.py
@@ -64,7 +64,7 @@ def list_dag_warnings(
readable_dag_warning_filter: ReadableDagWarningsFilterDep,
session: SessionDep,
) -> DAGWarningCollectionResponse:
- """Get a list of DAG warnings."""
+ """Get a list of Dag warnings."""
dag_warnings_select, total_entries = paginated_select(
statement=select(DagWarning).options(joinedload(DagWarning.dag_model)),
filters=[warning_type, dag_id, readable_dag_warning_filter],
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/calendar.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/calendar.py
index cd96b718a28..4f3746b669b 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/calendar.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/calendar.py
@@ -58,7 +58,7 @@ def get_calendar(
partition_date: Annotated[RangeFilter, Depends(datetime_range_filter_factory("partition_date", DagRun))],
granularity: Literal["hourly", "daily"] = "daily",
) -> CalendarTimeRangeCollectionResponse:
- """Get calendar data for a DAG including historical and planned DAG runs."""
+ """Get calendar data for a Dag including historical and planned Dag runs."""
dag = get_latest_version_of_dag(dag_bag, dag_id, session)
calendar_service = CalendarService()
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dags.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dags.py
index 7d41da74c3f..95728be5a21 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dags.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dags.py
@@ -126,7 +126,7 @@ def get_dags(
dag_runs_limit: int = 10,
) -> DAGWithLatestDagRunsCollectionResponse:
"""Get DAGs with recent DagRun."""
- # Fetch DAGs with their latest DagRun and apply filters
+ # Fetch Dags with their latest DagRun and apply filters
query = generate_dag_with_latest_run_query(
max_run_filters=[
last_dag_run_state,
@@ -165,14 +165,14 @@ def get_dags(
dags = [dag for dag in session.scalars(dags_select)]
- # Fetch favorite status for each DAG for the current user
+ # Fetch favorite status for each Dag for the current user
user_id = str(user.get_id())
favorites_select = select(DagFavorite.dag_id).where(
DagFavorite.user_id == user_id, DagFavorite.dag_id.in_([dag.dag_id for dag in dags])
)
favorite_dag_ids = set(session.scalars(favorites_select))
- # Populate the last 'dag_runs_limit' DagRuns for each DAG
+ # Populate the last 'dag_runs_limit' DagRuns for each Dag
recent_runs_subquery = (
select(
DagRun.dag_id,
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dashboard.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dashboard.py
index 1ce32badd4a..923bd3b55d1 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dashboard.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dashboard.py
@@ -125,7 +125,7 @@ def dag_stats(
session: SessionDep,
readable_dags_filter: ReadableDagsFilterDep,
) -> DashboardDagStatsResponse:
- """Return basic DAG stats with counts of DAGs in various states."""
+ """Return basic Dag stats with counts of Dags in various states."""
permitted_dag_ids = cast("set[str]", readable_dags_filter.value)
latest_dates_subq = (
select(DagRun.dag_id, func.max(DagRun.logical_date).label("max_logical_date"))
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/deadlines.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/deadlines.py
index 7e4e44e855b..d9cfea10d6d 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/deadlines.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/deadlines.py
@@ -94,10 +94,10 @@ def get_deadlines(
],
) -> DeadlineCollectionResponse:
"""
- Get deadlines for a DAG run.
+ Get deadlines for a Dag run.
This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve Deadlines for all
- DAGs and DAG runs.
+ Dags and Dag runs.
"""
query = (
select(Deadline)
@@ -172,7 +172,7 @@ def get_dag_deadline_alerts(
),
],
) -> DeadlineAlertCollectionResponse:
- """Get all deadline alerts defined on a DAG."""
+ """Get all deadline alerts defined on a Dag."""
serialized_dag = session.scalar(
select(SerializedDagModel)
.where(SerializedDagModel.dag_id == dag_id)
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py
index d3ddf8a2a52..72d92fbef2c 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py
@@ -164,9 +164,9 @@ def get_dag_structure(
depth=depth,
)
- # Retrieve, sort the previous DAG Runs
+ # Retrieve, sort the previous Dag Runs
base_query = select(DagRun.id).where(DagRun.dag_id == dag_id)
- # This comparison is to fall back to DAG timetable when no order_by is provided
+ # This comparison is to fall back to Dag timetable when no order_by is provided
if order_by.value == [order_by.get_primary_key_string()]:
ordering = list(latest_dag.timetable.run_ordering)
order_by = SortParam(
@@ -217,7 +217,7 @@ def get_dag_structure(
for serdag in session.scalars(serdags_query):
filtered_dag = serdag.dag
- # Apply the same filtering to historical DAG versions
+ # Apply the same filtering to historical Dag versions
if root:
filtered_dag = filtered_dag.partial_subset(
task_ids=root,
@@ -225,7 +225,7 @@ def get_dag_structure(
include_downstream=include_downstream,
depth=depth,
)
- # Merge immediately instead of collecting all DAGs in memory
+ # Merge immediately instead of collecting all Dags in memory
nodes = [task_group_to_dict_grid(x) for x in task_group_sort(filtered_dag.task_group)]
_merge_node_dicts(merged_nodes, nodes)
@@ -284,7 +284,7 @@ def get_grid_runs(
triggering_user_prefix: QueryDagRunTriggeringUserPrefixSearch,
) -> list[GridRunsResponse]:
"""Get info about a run for the grid."""
- # Retrieve, sort the previous DAG Runs
+ # Retrieve, sort the previous Dag Runs
has_missed_deadline = (
exists()
.where(Deadline.dagrun_id == DagRun.id, Deadline.missed.is_(True))
@@ -311,7 +311,7 @@ def get_grid_runs(
)
)
- # This comparison is to fall back to DAG timetable when no order_by is provided
+ # This comparison is to fall back to Dag timetable when no order_by is provided
if order_by.value == [order_by.get_primary_key_string()]:
latest_serdag = _get_latest_serdag(dag_id, session)
latest_dag = latest_serdag.dag
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/structure.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/structure.py
index bc7efc0a75a..87184788413 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/structure.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/structure.py
@@ -114,8 +114,8 @@ def structure_data(
# Dependencies not related to `dag_id` are ignored
if dependency_dag_id != dag_id and dependency.target != dag_id:
continue
- # When target is a real DAG ID (not a type label), hide it
- # if the caller cannot read that DAG.
+ # When target is a real Dag ID (not a type label), hide it
+ # if the caller cannot read that Dag.
if (
readable_dag_ids is not None
and dependency.target != dependency.dependency_type
diff --git a/airflow-core/src/airflow/api_fastapi/execution_api/AGENTS.md b/airflow-core/src/airflow/api_fastapi/execution_api/AGENTS.md
index 32500df182e..c72bd3aaafc 100644
--- a/airflow-core/src/airflow/api_fastapi/execution_api/AGENTS.md
+++ b/airflow-core/src/airflow/api_fastapi/execution_api/AGENTS.md
@@ -43,7 +43,7 @@ Adding a new Execution API feature touches multiple packages. All of these must
4. **Task SDK message types** — add request/response to `task-sdk/src/airflow/sdk/execution_time/comms.py`.
5. **Task SDK client** — add the client method in `task-sdk/src/airflow/sdk/api/client.py`.
6. **Supervisor** — handle the new message in `task-sdk/src/airflow/sdk/execution_time/supervisor.py`.
-7. **DAG processor & triggerer exclusions** — these use `InProcessExecutionAPI` and have explicit message type unions. Add new types to their handler or exclusion lists in `airflow/dag_processing/processor.py` and `airflow/jobs/triggerer_job_runner.py`.
+7. **Dag processor & triggerer exclusions** — these use `InProcessExecutionAPI` and have explicit message type unions. Add new types to their handler or exclusion lists in `airflow/dag_processing/processor.py` and `airflow/jobs/triggerer_job_runner.py`.
8. **Regenerate models** — `cd task-sdk && python dev/generate_task_sdk_models.py`.
9. **Tests** — if the new message type requires an API endpoint, add tests in all of these:
- `airflow-core/tests/unit/api_fastapi/execution_api/` — endpoint tests
@@ -59,7 +59,7 @@ Adding a new Execution API feature touches multiple packages. All of these must
- Message types: `task-sdk/src/airflow/sdk/execution_time/comms.py`
- Client: `task-sdk/src/airflow/sdk/api/client.py`
- Supervisor: `task-sdk/src/airflow/sdk/execution_time/supervisor.py`
-- DAG processor handler: `airflow-core/src/airflow/dag_processing/processor.py`
+- Dag processor handler: `airflow-core/src/airflow/dag_processing/processor.py`
- Triggerer handler: `airflow-core/src/airflow/jobs/triggerer_job_runner.py`
- Task SDK generated models: `task-sdk/src/airflow/sdk/api/datamodels/_generated.py`
- Full versioning guide: [`contributing-docs/19_execution_api_versioning.rst`](../../../../contributing-docs/19_execution_api_versioning.rst)
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts b/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
index 1958854733a..ca01ec0ea6b 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
@@ -485,7 +485,7 @@ export const ensureUseConfigServiceGetConfigValueData = (queryClient: QueryClien
export const ensureUseConfigServiceGetConfigsData = (queryClient: QueryClient) => queryClient.ensureQueryData({ queryKey: Common.UseConfigServiceGetConfigsKeyFn(), queryFn: () => ConfigService.getConfigs() });
/**
* List Dag Warnings
-* Get a list of DAG warnings.
+* Get a list of Dag warnings.
* @param data The data for the request.
* @param data.dagId
* @param data.warningType
@@ -1044,7 +1044,7 @@ export const ensureUseTaskInstanceServiceGetMappedTaskInstanceData = (queryClien
* @param data.taskDisplayNamePattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
* **Performance note:** this full-match pattern is evaluated as ``ILIKE '%term%'`` and most of the time prevents the database from using B-tree indexes, which can be very slow on large tables. Prefer the equivalent ``task_display_name_prefix_pattern`` parameter when possible.
-* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
+* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
* @param data.taskGroupId Filter by exact task group ID. Returns all tasks within the specified task group.
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
@@ -1611,9 +1611,9 @@ export const ensureUseDagVersionServiceGetDagVersionData = (queryClient: QueryCl
}) => queryClient.ensureQueryData({ queryKey: Common.UseDagVersionServiceGetDagVersionKeyFn({ dagId, versionNumber }), queryFn: () => DagVersionService.getDagVersion({ dagId, versionNumber }) });
/**
* Get Dag Versions
-* Get all DAG Versions.
+* Get all Dag Versions.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions for all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1732,17 +1732,17 @@ export const ensureUseDashboardServiceHistoricalMetricsData = (queryClient: Quer
}) => queryClient.ensureQueryData({ queryKey: Common.UseDashboardServiceHistoricalMetricsKeyFn({ endDate, startDate }), queryFn: () => DashboardService.historicalMetrics({ endDate, startDate }) });
/**
* Dag Stats
-* Return basic DAG stats with counts of DAGs in various states.
+* Return basic Dag stats with counts of Dags in various states.
* @returns DashboardDagStatsResponse Successful Response
* @throws ApiError
*/
export const ensureUseDashboardServiceDagStatsData = (queryClient: QueryClient) => queryClient.ensureQueryData({ queryKey: Common.UseDashboardServiceDagStatsKeyFn(), queryFn: () => DashboardService.dagStats() });
/**
* Get Deadlines
-* Get deadlines for a DAG run.
+* Get deadlines for a Dag run.
*
* This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve Deadlines for all
-* DAGs and DAG runs.
+* Dags and Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1779,7 +1779,7 @@ export const ensureUseDeadlinesServiceGetDeadlinesData = (queryClient: QueryClie
}) => queryClient.ensureQueryData({ queryKey: Common.UseDeadlinesServiceGetDeadlinesKeyFn({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, deadlineTimeLte, lastUpdatedAtGt, lastUpdatedAtGte, lastUpdatedAtLt, lastUpdatedAtLte, limit, missed, offset, orderBy }), queryFn: () => DeadlinesService.getDeadlines({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, deadlineTimeLte, lastUpdatedAtGt, lastUpdatedAtGte, lastUpdatedAtLt, lastUpdatedAtLte, limit, misse [...]
/**
* Get Dag Deadline Alerts
-* Get all deadline alerts defined on a DAG.
+* Get all deadline alerts defined on a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1931,7 +1931,7 @@ export const ensureUseGanttServiceGetGanttDataData = (queryClient: QueryClient,
}) => queryClient.ensureQueryData({ queryKey: Common.UseGanttServiceGetGanttDataKeyFn({ dagId, runId }), queryFn: () => GanttService.getGanttData({ dagId, runId }) });
/**
* Get Calendar
-* Get calendar data for a DAG including historical and planned DAG runs.
+* Get calendar data for a Dag including historical and planned Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.granularity
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts b/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
index 71436325670..855bf502b3e 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
@@ -485,7 +485,7 @@ export const prefetchUseConfigServiceGetConfigValue = (queryClient: QueryClient,
export const prefetchUseConfigServiceGetConfigs = (queryClient: QueryClient) => queryClient.prefetchQuery({ queryKey: Common.UseConfigServiceGetConfigsKeyFn(), queryFn: () => ConfigService.getConfigs() });
/**
* List Dag Warnings
-* Get a list of DAG warnings.
+* Get a list of Dag warnings.
* @param data The data for the request.
* @param data.dagId
* @param data.warningType
@@ -1044,7 +1044,7 @@ export const prefetchUseTaskInstanceServiceGetMappedTaskInstance = (queryClient:
* @param data.taskDisplayNamePattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
* **Performance note:** this full-match pattern is evaluated as ``ILIKE '%term%'`` and most of the time prevents the database from using B-tree indexes, which can be very slow on large tables. Prefer the equivalent ``task_display_name_prefix_pattern`` parameter when possible.
-* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
+* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
* @param data.taskGroupId Filter by exact task group ID. Returns all tasks within the specified task group.
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
@@ -1611,9 +1611,9 @@ export const prefetchUseDagVersionServiceGetDagVersion = (queryClient: QueryClie
}) => queryClient.prefetchQuery({ queryKey: Common.UseDagVersionServiceGetDagVersionKeyFn({ dagId, versionNumber }), queryFn: () => DagVersionService.getDagVersion({ dagId, versionNumber }) });
/**
* Get Dag Versions
-* Get all DAG Versions.
+* Get all Dag Versions.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions for all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1732,17 +1732,17 @@ export const prefetchUseDashboardServiceHistoricalMetrics = (queryClient: QueryC
}) => queryClient.prefetchQuery({ queryKey: Common.UseDashboardServiceHistoricalMetricsKeyFn({ endDate, startDate }), queryFn: () => DashboardService.historicalMetrics({ endDate, startDate }) });
/**
* Dag Stats
-* Return basic DAG stats with counts of DAGs in various states.
+* Return basic Dag stats with counts of Dags in various states.
* @returns DashboardDagStatsResponse Successful Response
* @throws ApiError
*/
export const prefetchUseDashboardServiceDagStats = (queryClient: QueryClient) => queryClient.prefetchQuery({ queryKey: Common.UseDashboardServiceDagStatsKeyFn(), queryFn: () => DashboardService.dagStats() });
/**
* Get Deadlines
-* Get deadlines for a DAG run.
+* Get deadlines for a Dag run.
*
* This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve Deadlines for all
-* DAGs and DAG runs.
+* Dags and Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1779,7 +1779,7 @@ export const prefetchUseDeadlinesServiceGetDeadlines = (queryClient: QueryClient
}) => queryClient.prefetchQuery({ queryKey: Common.UseDeadlinesServiceGetDeadlinesKeyFn({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, deadlineTimeLte, lastUpdatedAtGt, lastUpdatedAtGte, lastUpdatedAtLt, lastUpdatedAtLte, limit, missed, offset, orderBy }), queryFn: () => DeadlinesService.getDeadlines({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, deadlineTimeLte, lastUpdatedAtGt, lastUpdatedAtGte, lastUpdatedAtLt, lastUpdatedAtLte, limit, missed, [...]
/**
* Get Dag Deadline Alerts
-* Get all deadline alerts defined on a DAG.
+* Get all deadline alerts defined on a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1931,7 +1931,7 @@ export const prefetchUseGanttServiceGetGanttData = (queryClient: QueryClient, {
}) => queryClient.prefetchQuery({ queryKey: Common.UseGanttServiceGetGanttDataKeyFn({ dagId, runId }), queryFn: () => GanttService.getGanttData({ dagId, runId }) });
/**
* Get Calendar
-* Get calendar data for a DAG including historical and planned DAG runs.
+* Get calendar data for a Dag including historical and planned Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.granularity
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts b/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
index f7c589343fc..44b1386c99c 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
@@ -485,7 +485,7 @@ export const useConfigServiceGetConfigValue = <TData = Common.ConfigServiceGetCo
export const useConfigServiceGetConfigs = <TData = Common.ConfigServiceGetConfigsDefaultResponse, TError = unknown, TQueryKey extends Array<unknown> = unknown[]>(queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey: Common.UseConfigServiceGetConfigsKeyFn(queryKey), queryFn: () => ConfigService.getConfigs() as TData, ...options });
/**
* List Dag Warnings
-* Get a list of DAG warnings.
+* Get a list of Dag warnings.
* @param data The data for the request.
* @param data.dagId
* @param data.warningType
@@ -1044,7 +1044,7 @@ export const useTaskInstanceServiceGetMappedTaskInstance = <TData = Common.TaskI
* @param data.taskDisplayNamePattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
* **Performance note:** this full-match pattern is evaluated as ``ILIKE '%term%'`` and most of the time prevents the database from using B-tree indexes, which can be very slow on large tables. Prefer the equivalent ``task_display_name_prefix_pattern`` parameter when possible.
-* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
+* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
* @param data.taskGroupId Filter by exact task group ID. Returns all tasks within the specified task group.
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
@@ -1611,9 +1611,9 @@ export const useDagVersionServiceGetDagVersion = <TData = Common.DagVersionServi
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey: Common.UseDagVersionServiceGetDagVersionKeyFn({ dagId, versionNumber }, queryKey), queryFn: () => DagVersionService.getDagVersion({ dagId, versionNumber }) as TData, ...options });
/**
* Get Dag Versions
-* Get all DAG Versions.
+* Get all Dag Versions.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions for all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1732,17 +1732,17 @@ export const useDashboardServiceHistoricalMetrics = <TData = Common.DashboardSer
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey: Common.UseDashboardServiceHistoricalMetricsKeyFn({ endDate, startDate }, queryKey), queryFn: () => DashboardService.historicalMetrics({ endDate, startDate }) as TData, ...options });
/**
* Dag Stats
-* Return basic DAG stats with counts of DAGs in various states.
+* Return basic Dag stats with counts of Dags in various states.
* @returns DashboardDagStatsResponse Successful Response
* @throws ApiError
*/
export const useDashboardServiceDagStats = <TData = Common.DashboardServiceDagStatsDefaultResponse, TError = unknown, TQueryKey extends Array<unknown> = unknown[]>(queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey: Common.UseDashboardServiceDagStatsKeyFn(queryKey), queryFn: () => DashboardService.dagStats() as TData, ...options });
/**
* Get Deadlines
-* Get deadlines for a DAG run.
+* Get deadlines for a Dag run.
*
* This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve Deadlines for all
-* DAGs and DAG runs.
+* Dags and Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1779,7 +1779,7 @@ export const useDeadlinesServiceGetDeadlines = <TData = Common.DeadlinesServiceG
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey: Common.UseDeadlinesServiceGetDeadlinesKeyFn({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, deadlineTimeLte, lastUpdatedAtGt, lastUpdatedAtGte, lastUpdatedAtLt, lastUpdatedAtLte, limit, missed, offset, orderBy }, queryKey), queryFn: () => DeadlinesService.getDeadlines({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, [...]
/**
* Get Dag Deadline Alerts
-* Get all deadline alerts defined on a DAG.
+* Get all deadline alerts defined on a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1931,7 +1931,7 @@ export const useGanttServiceGetGanttData = <TData = Common.GanttServiceGetGanttD
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey: Common.UseGanttServiceGetGanttDataKeyFn({ dagId, runId }, queryKey), queryFn: () => GanttService.getGanttData({ dagId, runId }) as TData, ...options });
/**
* Get Calendar
-* Get calendar data for a DAG including historical and planned DAG runs.
+* Get calendar data for a Dag including historical and planned Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.granularity
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts b/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
index 2a29df44c2a..c3553e24046 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
@@ -485,7 +485,7 @@ export const useConfigServiceGetConfigValueSuspense = <TData = Common.ConfigServ
export const useConfigServiceGetConfigsSuspense = <TData = Common.ConfigServiceGetConfigsDefaultResponse, TError = unknown, TQueryKey extends Array<unknown> = unknown[]>(queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey: Common.UseConfigServiceGetConfigsKeyFn(queryKey), queryFn: () => ConfigService.getConfigs() as TData, ...options });
/**
* List Dag Warnings
-* Get a list of DAG warnings.
+* Get a list of Dag warnings.
* @param data The data for the request.
* @param data.dagId
* @param data.warningType
@@ -1044,7 +1044,7 @@ export const useTaskInstanceServiceGetMappedTaskInstanceSuspense = <TData = Comm
* @param data.taskDisplayNamePattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
* **Performance note:** this full-match pattern is evaluated as ``ILIKE '%term%'`` and most of the time prevents the database from using B-tree indexes, which can be very slow on large tables. Prefer the equivalent ``task_display_name_prefix_pattern`` parameter when possible.
-* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
+* @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matchin [...]
* @param data.taskGroupId Filter by exact task group ID. Returns all tasks within the specified task group.
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
@@ -1611,9 +1611,9 @@ export const useDagVersionServiceGetDagVersionSuspense = <TData = Common.DagVers
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey: Common.UseDagVersionServiceGetDagVersionKeyFn({ dagId, versionNumber }, queryKey), queryFn: () => DagVersionService.getDagVersion({ dagId, versionNumber }) as TData, ...options });
/**
* Get Dag Versions
-* Get all DAG Versions.
+* Get all Dag Versions.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions for all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1732,17 +1732,17 @@ export const useDashboardServiceHistoricalMetricsSuspense = <TData = Common.Dash
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey: Common.UseDashboardServiceHistoricalMetricsKeyFn({ endDate, startDate }, queryKey), queryFn: () => DashboardService.historicalMetrics({ endDate, startDate }) as TData, ...options });
/**
* Dag Stats
-* Return basic DAG stats with counts of DAGs in various states.
+* Return basic Dag stats with counts of Dags in various states.
* @returns DashboardDagStatsResponse Successful Response
* @throws ApiError
*/
export const useDashboardServiceDagStatsSuspense = <TData = Common.DashboardServiceDagStatsDefaultResponse, TError = unknown, TQueryKey extends Array<unknown> = unknown[]>(queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey: Common.UseDashboardServiceDagStatsKeyFn(queryKey), queryFn: () => DashboardService.dagStats() as TData, ...options });
/**
* Get Deadlines
-* Get deadlines for a DAG run.
+* Get deadlines for a Dag run.
*
* This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve Deadlines for all
-* DAGs and DAG runs.
+* Dags and Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1779,7 +1779,7 @@ export const useDeadlinesServiceGetDeadlinesSuspense = <TData = Common.Deadlines
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey: Common.UseDeadlinesServiceGetDeadlinesKeyFn({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlineTimeLt, deadlineTimeLte, lastUpdatedAtGt, lastUpdatedAtGte, lastUpdatedAtLt, lastUpdatedAtLte, limit, missed, offset, orderBy }, queryKey), queryFn: () => DeadlinesService.getDeadlines({ dagId, dagRunId, deadlineTimeGt, deadlineTimeGte, deadlin [...]
/**
* Get Dag Deadline Alerts
-* Get all deadline alerts defined on a DAG.
+* Get all deadline alerts defined on a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -1931,7 +1931,7 @@ export const useGanttServiceGetGanttDataSuspense = <TData = Common.GanttServiceG
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>, "queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey: Common.UseGanttServiceGetGanttDataKeyFn({ dagId, runId }, queryKey), queryFn: () => GanttService.getGanttData({ dagId, runId }) as TData, ...options });
/**
* Get Calendar
-* Get calendar data for a DAG including historical and planned DAG runs.
+* Get calendar data for a Dag including historical and planned Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.granularity
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts b/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
index a92d59a7be8..09647aa033a 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
@@ -1389,7 +1389,7 @@ export class ConfigService {
export class DagWarningService {
/**
* List Dag Warnings
- * Get a list of DAG warnings.
+ * Get a list of Dag warnings.
* @param data The data for the request.
* @param data.dagId
* @param data.warningType
@@ -2465,7 +2465,7 @@ export class TaskInstanceService {
* @param data.taskDisplayNamePattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
* **Performance note:** this full-match pattern is evaluated as ``ILIKE '%term%'`` and most of the time prevents the database from using B-tree indexes, which can be very slow on large tables. Prefer the equivalent ``task_display_name_prefix_pattern`` parameter when possible.
- * @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before ma [...]
+ * @param data.taskDisplayNamePrefixPattern Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before ma [...]
* @param data.taskGroupId Filter by exact task group ID. Returns all tasks within the specified task group.
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). or the pipe `|` operator for OR logic (e.g. `dag1 | dag2`). Regular expressions are **not** supported.
*
@@ -3900,9 +3900,9 @@ export class DagVersionService {
/**
* Get Dag Versions
- * Get all DAG Versions.
+ * Get all Dag Versions.
*
- * This endpoint allows specifying `~` as the dag_id to retrieve DAG Versions for all DAGs.
+ * This endpoint allows specifying `~` as the dag_id to retrieve Dag Versions for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -4163,7 +4163,7 @@ export class DashboardService {
/**
* Dag Stats
- * Return basic DAG stats with counts of DAGs in various states.
+ * Return basic Dag stats with counts of Dags in various states.
* @returns DashboardDagStatsResponse Successful Response
* @throws ApiError
*/
@@ -4179,10 +4179,10 @@ export class DashboardService {
export class DeadlinesService {
/**
* Get Deadlines
- * Get deadlines for a DAG run.
+ * Get deadlines for a Dag run.
*
* This endpoint allows specifying `~` as the dag_id and dag_run_id to retrieve Deadlines for all
- * DAGs and DAG runs.
+ * Dags and Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -4233,7 +4233,7 @@ export class DeadlinesService {
/**
* Get Dag Deadline Alerts
- * Get all deadline alerts defined on a DAG.
+ * Get all deadline alerts defined on a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.limit
@@ -4474,7 +4474,7 @@ export class GanttService {
export class CalendarService {
/**
* Get Calendar
- * Get calendar data for a DAG including historical and planned DAG runs.
+ * Get calendar data for a Dag including historical and planned Dag runs.
* @param data The data for the request.
* @param data.dagId
* @param data.granularity
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts b/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
index a7259db3996..7612675bb64 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
@@ -3399,7 +3399,7 @@ export type GetTaskInstancesData = {
*/
taskDisplayNamePattern?: string | null;
/**
- * Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific DAG in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matching so the range scan stays index-comp [...]
+ * Prefix match on task display name: optional ``_task_display_property_value`` else ``task_id`` (same as ``coalesce``). Case-sensitive. Index-friendly alternative to ``task_display_name_pattern``. On large databases, combine with ``dag_id_prefix_pattern`` (or a specific Dag in the path) so ``(dag_id, task_id, ...)`` indexes apply. Use ``|`` for OR. Use ``~`` to match all. Trailing non-alphanumeric characters in the term are stripped before matching so the range scan stays index-comp [...]
*/
taskDisplayNamePrefixPattern?: string | null;
/**