This is an automated email from the ASF dual-hosted git repository.
choo121600 pushed a commit to branch v3-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-2-test by this push:
new c8ae315da7e [v3-2-test] Align Dag capitalization from "DAG" to "Dag"
for api_fastapi (#66099) (#66135)
c8ae315da7e is described below
commit c8ae315da7e876df6a22d62613c48b1038f41d6e
Author: Yeonguk Choo <[email protected]>
AuthorDate: Thu Apr 30 17:14:26 2026 +0900
[v3-2-test] Align Dag capitalization from "DAG" to "Dag" for api_fastapi
(#66099) (#66135)
Backport of #66099 to v3-2-test.
Source-level docstring/comment changes from #66099 were re-applied on
v3-2-test (cherry-pick failed on auto-generated openapi-gen files due to
divergence from main). The OpenAPI YAML and UI TypeScript client were
regenerated from the updated sources.
Note: deadlines.py changes from #66099 were skipped because the v3-2-test
endpoint has different docstrings; the corresponding generated artefacts
were left as-is.
---
.../api_fastapi/auth/managers/base_auth_manager.py | 16 ++++++++--------
.../api_fastapi/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 | 4 ++--
.../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 +++---
.../airflow/api_fastapi/core_api/routes/ui/dashboard.py | 2 +-
.../src/airflow/api_fastapi/core_api/routes/ui/grid.py | 12 ++++++------
.../airflow/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 | 12 ++++++------
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 12 ++++++------
.../src/airflow/ui/openapi-gen/queries/queries.ts | 12 ++++++------
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 12 ++++++------
.../src/airflow/ui/openapi-gen/requests/services.gen.ts | 12 ++++++------
.../src/airflow/ui/openapi-gen/requests/types.gen.ts | 2 +-
22 files changed, 77 insertions(+), 77 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 a26a4413aad..a9188b4f82b 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
@@ -234,13 +234,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
@@ -551,7 +551,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
@@ -591,13 +591,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 0f89fd20c4c..0982f501863 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
@@ -70,7 +70,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 3ca4483ce87..01cfcf09f69 100644
--- a/airflow-core/src/airflow/api_fastapi/common/dagbag.py
+++ b/airflow-core/src/airflow/api_fastapi/common/dagbag.py
@@ -71,11 +71,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 e4b4a43abf1..c77e37f6e69 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':
@@ -1366,7 +1366,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 8636a47a04e..33e96429152 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 51da7966919..72f51490f12 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
@@ -125,7 +125,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,
@@ -164,14 +164,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/grid.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py
index a4eb1198c07..69d5f60785e 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
@@ -165,9 +165,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(
@@ -218,7 +218,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,
@@ -226,7 +226,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)
@@ -285,7 +285,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))
@@ -320,7 +320,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 95e878c4809..517d097aed1 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,7 +1732,7 @@ 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
*/
@@ -1893,7 +1893,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 9107c9372c3..b1e731614a0 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,7 +1732,7 @@ 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
*/
@@ -1893,7 +1893,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 76621317ac4..a2c9422a18d 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,7 +1732,7 @@ 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
*/
@@ -1893,7 +1893,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 396d36a8f8a..7a1e9aab08c 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,7 +1732,7 @@ 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
*/
@@ -1893,7 +1893,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 03f2c29a498..9793dcc1a6e 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
*/
@@ -4422,7 +4422,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 3632486a2e1..d54964449db 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
@@ -3339,7 +3339,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;
/**
