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 c7908907a42 Align Dag capitalization from "DAG" to "Dag" in core_api
(#66211) (#66304)
c7908907a42 is described below
commit c7908907a425eb2f58dbb3c37c5d836648136663
Author: Yeonguk Choo <[email protected]>
AuthorDate: Mon May 4 10:54:39 2026 +0900
Align Dag capitalization from "DAG" to "Dag" in core_api (#66211) (#66304)
* refactor: Align Dag capitalization from "DAG" to "Dag" in core_api
* Align public API error tests with Dag capitalization
(cherry picked from commit 170ac6ede1628c4829c6595a1c2be08b00fffb5d)
Co-authored-by: hojeong park <[email protected]>
---
.../api_fastapi/core_api/openapi/_private_ui.yaml | 2 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 52 ++++++++++----------
.../api_fastapi/core_api/routes/public/assets.py | 14 +++---
.../core_api/routes/public/dag_parsing.py | 2 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 26 +++++-----
.../core_api/routes/public/dag_sources.py | 2 +-
.../api_fastapi/core_api/routes/public/dag_tags.py | 2 +-
.../api_fastapi/core_api/routes/public/dags.py | 32 ++++++-------
.../core_api/routes/public/import_error.py | 32 ++++++-------
.../core_api/routes/public/task_instances.py | 2 +-
.../api_fastapi/core_api/routes/public/tasks.py | 2 +-
.../api_fastapi/core_api/routes/public/xcom.py | 6 +--
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 2 +-
.../core_api/services/public/task_instances.py | 2 +-
.../api_fastapi/core_api/services/ui/calendar.py | 10 ++--
.../core_api/services/ui/dependencies.py | 2 +-
.../api_fastapi/core_api/services/ui/grid.py | 6 +--
.../api_fastapi/core_api/services/ui/task_group.py | 2 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 28 +++++------
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 28 +++++------
.../src/airflow/ui/openapi-gen/queries/queries.ts | 56 +++++++++++-----------
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 28 +++++------
.../ui/openapi-gen/requests/services.gen.ts | 56 +++++++++++-----------
.../core_api/routes/public/test_assets.py | 6 +--
.../core_api/routes/public/test_dag_run.py | 6 +--
.../core_api/routes/public/test_import_error.py | 6 +--
.../core_api/routes/public/test_task_instances.py | 4 +-
27 files changed, 208 insertions(+), 208 deletions(-)
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 cc9e6326aeb..9d116224daf 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
@@ -225,7 +225,7 @@ paths:
tags:
- DAG
summary: Get Dags
- description: Get DAGs with recent DagRun.
+ description: Get Dags with recent DagRun.
operationId: get_dags_ui
security:
- OAuth2PasswordBearer: []
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 0eb8a116acb..767cdfb29d7 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
@@ -596,7 +596,7 @@ paths:
tags:
- Asset
summary: Materialize Asset
- description: Materialize an asset by triggering a DAG run that produces
it.
+ description: Materialize an asset by triggering a Dag run that produces
it.
operationId: materialize_asset
security:
- OAuth2PasswordBearer: []
@@ -813,7 +813,7 @@ paths:
tags:
- Asset
summary: Get Dag Asset Queued Events
- description: Get queued asset events for a DAG.
+ description: Get queued asset events for a Dag.
operationId: get_dag_asset_queued_events
security:
- OAuth2PasswordBearer: []
@@ -919,7 +919,7 @@ paths:
tags:
- Asset
summary: Get Dag Asset Queued Event
- description: Get a queued asset event for a DAG.
+ description: Get a queued asset event for a Dag.
operationId: get_dag_asset_queued_event
security:
- OAuth2PasswordBearer: []
@@ -980,7 +980,7 @@ paths:
tags:
- Asset
summary: Delete Dag Asset Queued Event
- description: Delete a queued asset event for a DAG.
+ description: Delete a queued asset event for a Dag.
operationId: delete_dag_asset_queued_event
security:
- OAuth2PasswordBearer: []
@@ -1926,7 +1926,7 @@ paths:
tags:
- DagRun
summary: Delete Dag Run
- description: Delete a DAG Run entry.
+ description: Delete a Dag Run entry.
operationId: delete_dag_run
security:
- OAuth2PasswordBearer: []
@@ -1981,7 +1981,7 @@ paths:
tags:
- DagRun
summary: Patch Dag Run
- description: Modify a DAG Run.
+ description: Modify a Dag Run.
operationId: patch_dag_run
security:
- OAuth2PasswordBearer: []
@@ -2174,11 +2174,11 @@ paths:
tags:
- DagRun
summary: Get Dag Runs
- description: 'Get all DAG Runs.
+ description: 'Get all Dag Runs.
This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs
for
- all DAGs.
+ all Dags.
Supports two pagination modes:
@@ -2732,7 +2732,7 @@ paths:
tags:
- DagRun
summary: Trigger Dag Run
- description: Trigger a DAG.
+ description: Trigger a Dag.
operationId: trigger_dag_run
security:
- OAuth2PasswordBearer: []
@@ -2801,7 +2801,7 @@ paths:
if requested.'
description: "\U0001F6A7 This is an experimental endpoint and may change
or\
\ be removed without notice.Successful response are streamed as
newline-delimited\
- \ JSON (NDJSON). Each line is a JSON object representing the DAG run
state."
+ \ JSON (NDJSON). Each line is a JSON object representing the Dag run
state."
operationId: wait_dag_run_until_finished
security:
- OAuth2PasswordBearer: []
@@ -2883,7 +2883,7 @@ paths:
tags:
- DagRun
summary: Get List Dag Runs Batch
- description: Get a list of DAG Runs.
+ description: Get a list of Dag Runs.
operationId: get_list_dag_runs_batch
security:
- OAuth2PasswordBearer: []
@@ -3324,7 +3324,7 @@ paths:
tags:
- DAG
summary: Get Dags
- description: Get all DAGs.
+ description: Get all Dags.
operationId: get_dags
security:
- OAuth2PasswordBearer: []
@@ -3675,13 +3675,13 @@ paths:
tags:
- DAG
summary: Patch Dags
- description: 'Patch multiple DAGs.
+ description: 'Patch multiple Dags.
- If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided,
no DAGs
+ If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided,
no Dags
will be
- matched regardless of other filters. To match all DAGs, pass a
wildcard value
+ matched regardless of other filters. To match all Dags, pass a
wildcard value
such as
`~` or `%` for `dag_id_pattern`.'
@@ -3851,7 +3851,7 @@ paths:
tags:
- DAG
summary: Get Dag
- description: Get basic information about a DAG.
+ description: Get basic information about a Dag.
operationId: get_dag
security:
- OAuth2PasswordBearer: []
@@ -3904,7 +3904,7 @@ paths:
tags:
- DAG
summary: Patch Dag
- description: Patch the specific DAG.
+ description: Patch the specific Dag.
operationId: patch_dag
security:
- OAuth2PasswordBearer: []
@@ -3973,7 +3973,7 @@ paths:
tags:
- DAG
summary: Delete Dag
- description: Delete the specific DAG.
+ description: Delete the specific Dag.
operationId: delete_dag
security:
- OAuth2PasswordBearer: []
@@ -4026,7 +4026,7 @@ paths:
tags:
- DAG
summary: Get Dag Details
- description: Get details of DAG.
+ description: Get details of Dag.
operationId: get_dag_details
security:
- OAuth2PasswordBearer: []
@@ -4080,7 +4080,7 @@ paths:
tags:
- DAG
summary: Favorite Dag
- description: Mark the DAG as favorite.
+ description: Mark the Dag as favorite.
operationId: favorite_dag
security:
- OAuth2PasswordBearer: []
@@ -4124,7 +4124,7 @@ paths:
tags:
- DAG
summary: Unfavorite Dag
- description: Unmark the DAG as favorite.
+ description: Unmark the Dag as favorite.
operationId: unfavorite_dag
security:
- OAuth2PasswordBearer: []
@@ -5787,7 +5787,7 @@ paths:
This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id
to
- retrieve XCom entries for all DAGs.'
+ retrieve XCom entries for all Dags.'
operationId: get_xcom_entries
security:
- OAuth2PasswordBearer: []
@@ -7395,7 +7395,7 @@ paths:
This endpoint allows specifying `~` as the dag_id, dag_run_id
- to retrieve task instances for all DAGs and DAG runs.
+ to retrieve task instances for all Dags and Dag runs.
Supports two pagination modes:
@@ -8586,7 +8586,7 @@ paths:
tags:
- Task
summary: Get Tasks
- description: Get tasks for DAG.
+ description: Get tasks for Dag.
operationId: get_tasks
security:
- OAuth2PasswordBearer: []
@@ -9253,7 +9253,7 @@ paths:
tags:
- DAG Parsing
summary: Reparse Dag File
- description: Request re-parsing a DAG file.
+ description: Request re-parsing a Dag file.
operationId: reparse_dag_file
security:
- OAuth2PasswordBearer: []
@@ -9300,7 +9300,7 @@ paths:
tags:
- DAG
summary: Get Dag Tags
- description: Get all DAG tags.
+ description: Get all Dag tags.
operationId: get_dag_tags
security:
- OAuth2PasswordBearer: []
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
index dc0db3d5914..e5d9d4bf228 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
@@ -398,7 +398,7 @@ def materialize_asset(
session: SessionDep,
body: MaterializeAssetBody | None = None,
) -> DAGRunResponse:
- """Materialize an asset by triggering a DAG run that produces it."""
+ """Materialize an asset by triggering a Dag run that produces it."""
dag_id_it = iter(
session.scalars(
select(TaskOutletAssetReference.dag_id)
@@ -409,11 +409,11 @@ def materialize_asset(
)
if (dag_id := next(dag_id_it, None)) is None:
- raise HTTPException(status.HTTP_404_NOT_FOUND, f"No DAG materializes
asset with ID: {asset_id}")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, f"No Dag materializes
asset with ID: {asset_id}")
if next(dag_id_it, None) is not None:
raise HTTPException(
status.HTTP_409_CONFLICT,
- f"More than one DAG materializes asset with ID: {asset_id}",
+ f"More than one Dag materializes asset with ID: {asset_id}",
)
if not get_auth_manager().is_authorized_dag(
@@ -424,7 +424,7 @@ def materialize_asset(
):
raise HTTPException(
status.HTTP_403_FORBIDDEN,
- f"User is not authorized to trigger a run for DAG: {dag_id} that
materializes this asset",
+ f"User is not authorized to trigger a run for Dag: {dag_id} that
materializes this asset",
)
dag = get_latest_version_of_dag(dag_bag, dag_id, session)
@@ -562,7 +562,7 @@ def get_dag_asset_queued_events(
session: SessionDep,
before: OptionalDateTimeQuery = None,
) -> QueuedEventCollectionResponse:
- """Get queued asset events for a DAG."""
+ """Get queued asset events for a Dag."""
where_clause = _generate_queued_event_where_clause(
dag_id=dag_id, before=before,
permitted_dag_ids=readable_dags_filter.value
)
@@ -599,7 +599,7 @@ def get_dag_asset_queued_event(
session: SessionDep,
before: OptionalDateTimeQuery = None,
) -> QueuedEventResponse:
- """Get a queued asset event for a DAG."""
+ """Get a queued asset event for a Dag."""
where_clause = _generate_queued_event_where_clause(
dag_id=dag_id, asset_id=asset_id, before=before,
permitted_dag_ids=readable_dags_filter.value
)
@@ -702,7 +702,7 @@ def delete_dag_asset_queued_event(
session: SessionDep,
before: OptionalDateTimeQuery = None,
):
- """Delete a queued asset event for a DAG."""
+ """Delete a queued asset event for a Dag."""
where_clause = _generate_queued_event_where_clause(
dag_id=dag_id, before=before, asset_id=asset_id,
permitted_dag_ids=readable_dags_filter.value
)
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_parsing.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_parsing.py
index fe2b80e8c11..5a9a5d7e397 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_parsing.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_parsing.py
@@ -49,7 +49,7 @@ def reparse_dag_file(
session: SessionDep,
request: Request,
) -> None:
- """Request re-parsing a DAG file."""
+ """Request re-parsing a Dag file."""
secret_key = request.app.state.secret_key
auth_s = URLSafeSerializer(secret_key)
try:
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_run.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_run.py
index ef9983c7c61..e168bd782f3 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_run.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_run.py
@@ -146,7 +146,7 @@ def get_dag_run(dag_id: str, dag_run_id: str, session:
SessionDep) -> DAGRunResp
],
)
def delete_dag_run(dag_id: str, dag_run_id: str, session: SessionDep):
- """Delete a DAG Run entry."""
+ """Delete a Dag Run entry."""
dag_run = session.scalar(select(DagRun).filter_by(dag_id=dag_id,
run_id=dag_run_id))
deletable_states = {s.value for s in DAGRunPatchStates}
@@ -189,7 +189,7 @@ def patch_dag_run(
user: GetUserDep,
update_mask: list[str] | None = Query(None),
) -> DAGRunResponse:
- """Modify a DAG Run."""
+ """Modify a Dag Run."""
dag_run = session.scalar(
select(DagRun).filter_by(dag_id=dag_id,
run_id=dag_run_id).options(joinedload(DagRun.dag_model))
)
@@ -241,7 +241,7 @@ def patch_dag_run(
final_dag_run = session.get(DagRun, dag_run.id)
if not final_dag_run:
- raise HTTPException(status.HTTP_404_NOT_FOUND, "DAG run not found
after update")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, "Dag run not found
after update")
return final_dag_run
@@ -335,7 +335,7 @@ def clear_dag_run(
)
dag_run_cleared = session.scalar(select(DagRun).where(DagRun.id ==
dag_run.id))
if not dag_run_cleared:
- raise HTTPException(status.HTTP_404_NOT_FOUND, "DAG run not found
after clearing")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, "Dag run not found
after clearing")
return dag_run_cleared
@@ -420,9 +420,9 @@ def get_dag_runs(
),
) -> DAGRunCollectionResponse:
"""
- Get all DAG Runs.
+ Get all Dag Runs.
- This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all DAGs.
+ This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all Dags.
Supports two pagination modes:
@@ -437,7 +437,7 @@ def get_dag_runs(
query = select(DagRun).options(*eager_load_dag_run_for_list())
if dag_id != "~":
- get_latest_version_of_dag(dag_bag, dag_id, session) # Check if the
DAG exists.
+ get_latest_version_of_dag(dag_bag, dag_id, session) # Check if the
Dag exists.
query = query.filter(DagRun.dag_id == dag_id).options()
# Add join with DagVersion if dag_version filter is active
@@ -544,15 +544,15 @@ def trigger_dag_run(
session: SessionDep,
request: Request,
) -> DAGRunResponse:
- """Trigger a DAG."""
+ """Trigger a Dag."""
dm = session.scalar(select(DagModel).where(~DagModel.is_stale,
DagModel.dag_id == dag_id).limit(1))
if not dm:
- raise HTTPException(status.HTTP_404_NOT_FOUND, f"DAG with dag_id:
'{dag_id}' not found")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, f"Dag with dag_id:
'{dag_id}' not found")
if dm.has_import_errors:
raise HTTPException(
status.HTTP_400_BAD_REQUEST,
- f"DAG with dag_id: '{dag_id}' has import errors and cannot be
triggered",
+ f"Dag with dag_id: '{dag_id}' has import errors and cannot be
triggered",
)
if dm.allowed_run_types is not None and DagRunType.MANUAL not in
dm.allowed_run_types:
@@ -598,7 +598,7 @@ def trigger_dag_run(
"/{dag_run_id}/wait",
tags=["experimental"],
summary="Experimental: Wait for a dag run to complete, and return task
results if requested.",
- description="🚧 This is an experimental endpoint and may change or be
removed without notice.Successful response are streamed as newline-delimited
JSON (NDJSON). Each line is a JSON object representing the DAG run state.",
+ description="🚧 This is an experimental endpoint and may change or be
removed without notice.Successful response are streamed as newline-delimited
JSON (NDJSON). Each line is a JSON object representing the Dag run state.",
responses={
**create_openapi_http_exception_doc([status.HTTP_404_NOT_FOUND]),
status.HTTP_200_OK: {
@@ -641,7 +641,7 @@ def wait_dag_run_until_finished(
):
raise HTTPException(
status.HTTP_403_FORBIDDEN,
- "User is not authorized to read XCom data for this DAG",
+ "User is not authorized to read XCom data for this Dag",
)
if not session.scalar(select(1).where(DagRun.dag_id == dag_id,
DagRun.run_id == dag_run_id)):
raise HTTPException(
@@ -669,7 +669,7 @@ def get_list_dag_runs_batch(
readable_dag_runs_filter: ReadableDagRunsFilterDep,
session: SessionDep,
) -> DAGRunCollectionResponse:
- """Get a list of DAG Runs."""
+ """Get a list of Dag Runs."""
dag_ids = FilterParam(DagRun.dag_id, body.dag_ids, FilterOptionEnum.IN) #
type: ignore[arg-type]
logical_date = RangeFilter(
Range(
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_sources.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_sources.py
index c44fe9740a1..26920007672 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_sources.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_sources.py
@@ -62,7 +62,7 @@ def get_dag_source(
if not dag_version:
raise HTTPException(
status.HTTP_404_NOT_FOUND,
- f"The source code of the DAG {dag_id}, version_number
{version_number} was not found",
+ f"The source code of the Dag {dag_id}, version_number
{version_number} was not found",
)
if not dag_version.dag_code:
raise HTTPException(
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_tags.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_tags.py
index 531230de94c..b09f524c1ac 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_tags.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_tags.py
@@ -60,7 +60,7 @@ def get_dag_tags(
readable_tags_filter: ReadableTagsFilterDep,
session: SessionDep,
) -> DAGTagCollectionResponse:
- """Get all DAG tags."""
+ """Get all Dag tags."""
query = select(DagTag.name).group_by(DagTag.name)
dag_tags_select, total_entries = paginated_select(
statement=query,
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
index 87d06ed5349..355ce4ca7a5 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
@@ -137,7 +137,7 @@ def get_dags(
Depends(filter_param_factory(DagModel.timetable_type, list[str],
FilterOptionEnum.IN)),
],
) -> DAGCollectionResponse:
- """Get all DAGs."""
+ """Get all Dags."""
query = generate_dag_with_latest_run_query(
max_run_filters=[
dag_run_start_date_range,
@@ -199,7 +199,7 @@ def get_dag(
session: SessionDep,
dag_bag: DagBagDep,
) -> DAGResponse:
- """Get basic information about a DAG."""
+ """Get basic information about a Dag."""
dag = get_latest_version_of_dag(dag_bag, dag_id, session)
dag_model = session.get(DagModel, dag_id)
if not dag_model:
@@ -225,7 +225,7 @@ def get_dag(
def get_dag_details(
dag_id: str, session: SessionDep, dag_bag: DagBagDep, user: GetUserDep
) -> DAGDetailsResponse:
- """Get details of DAG."""
+ """Get details of Dag."""
dag = get_latest_version_of_dag(dag_bag, dag_id, session)
dag_model = session.get(DagModel, dag_id)
@@ -236,7 +236,7 @@ def get_dag_details(
if not key.startswith("_") and not hasattr(dag_model, key):
setattr(dag_model, key, value)
- # Check if this DAG is marked as favorite by the current user
+ # Check if this Dag is marked as favorite by the current user
user_id = str(user.get_id())
is_favorite = (
session.scalar(
@@ -245,7 +245,7 @@ def get_dag_details(
is not None
)
- # Count active (running + queued) DAG runs for this DAG
+ # Count active (running + queued) Dag runs for this Dag
active_runs_count = (
session.scalar(
select(func.count())
@@ -255,7 +255,7 @@ def get_dag_details(
or 0
)
- # Add is_favorite and active_runs_count fields to the DAG model
+ # Add is_favorite and active_runs_count fields to the Dag model
setattr(dag_model, "is_favorite", is_favorite)
setattr(dag_model, "active_runs_count", active_runs_count)
@@ -278,7 +278,7 @@ def patch_dag(
session: SessionDep,
update_mask: list[str] | None = Query(None),
) -> DAGResponse:
- """Patch the specific DAG."""
+ """Patch the specific Dag."""
dag = session.get(DagModel, dag_id)
if dag is None:
@@ -334,10 +334,10 @@ def patch_dags(
update_mask: list[str] | None = Query(None),
) -> DAGCollectionResponse:
"""
- Patch multiple DAGs.
+ Patch multiple Dags.
- If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided, no
DAGs will be
- matched regardless of other filters. To match all DAGs, pass a wildcard
value such as
+ If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided, no
Dags will be
+ matched regardless of other filters. To match all Dags, pass a wildcard
value such as
`~` or `%` for `dag_id_pattern`.
"""
if update_mask:
@@ -402,10 +402,10 @@ def patch_dags(
dependencies=[Depends(requires_access_dag(method="GET")),
Depends(action_logging())],
)
def favorite_dag(dag_id: str, session: SessionDep, user: GetUserDep):
- """Mark the DAG as favorite."""
+ """Mark the Dag as favorite."""
dag = session.get(DagModel, dag_id)
if not dag:
- raise HTTPException(status.HTTP_404_NOT_FOUND, detail=f"DAG with id
'{dag_id}' not found")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, detail=f"Dag with id
'{dag_id}' not found")
user_id = str(user.get_id())
session.execute(insert(DagFavorite).values(dag_id=dag_id, user_id=user_id))
@@ -418,10 +418,10 @@ def favorite_dag(dag_id: str, session: SessionDep, user:
GetUserDep):
dependencies=[Depends(requires_access_dag(method="GET")),
Depends(action_logging())],
)
def unfavorite_dag(dag_id: str, session: SessionDep, user: GetUserDep):
- """Unmark the DAG as favorite."""
+ """Unmark the Dag as favorite."""
dag = session.get(DagModel, dag_id)
if not dag:
- raise HTTPException(status.HTTP_404_NOT_FOUND, detail=f"DAG with id
'{dag_id}' not found")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, detail=f"Dag with id
'{dag_id}' not found")
user_id = str(user.get_id())
@@ -433,7 +433,7 @@ def unfavorite_dag(dag_id: str, session: SessionDep, user:
GetUserDep):
).first()
if not favorite_exists:
- raise HTTPException(status.HTTP_409_CONFLICT, detail="DAG is not
marked as favorite")
+ raise HTTPException(status.HTTP_409_CONFLICT, detail="Dag is not
marked as favorite")
session.execute(
delete(DagFavorite).where(
@@ -458,7 +458,7 @@ def delete_dag(
dag_id: str,
session: SessionDep,
) -> Response:
- """Delete the specific DAG."""
+ """Delete the specific Dag."""
try:
delete_dag_module.delete_dag(dag_id, session=session)
except DagNotFound:
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/import_error.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/import_error.py
index ad8f9ed6b96..02055f47d3b 100644
---
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/import_error.py
+++
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/import_error.py
@@ -54,7 +54,7 @@ from airflow.api_fastapi.core_api.security import (
from airflow.models import DagModel
from airflow.models.errors import ParseImportError
-REDACTED_STACKTRACE = "REDACTED - you do not have read permission on all DAGs
in the file"
+REDACTED_STACKTRACE = "REDACTED - you do not have read permission on all Dags
in the file"
import_error_router = AirflowRouter(tags=["Import Error"],
prefix="/importErrors")
@@ -96,8 +96,8 @@ def get_import_error(
).all()
)
- # No DAGs matched for this file -- either the file genuinely contains
- # no DAGs (parse failed before any DAG was defined), or the name keys
+ # No Dags matched for this file -- either the file genuinely contains
+ # no Dags (parse failed before any Dag was defined), or the name keys
# did not resolve. Redact the stacktrace rather than returning the raw
# error, so the response stays on the deny-by-default side of the
# authorization check.
@@ -105,14 +105,14 @@ def get_import_error(
error.stacktrace = REDACTED_STACKTRACE
return error
- # Can the user read any DAGs in the file?
+ # Can the user read any Dags in the file?
if not readable_dag_ids.intersection(file_dag_ids):
raise HTTPException(
status.HTTP_403_FORBIDDEN,
- "You do not have read permission on any of the DAGs in the file",
+ "You do not have read permission on any of the Dags in the file",
)
- # Check if user has read access to all the DAGs defined in the file
+ # Check if user has read access to all the Dags defined in the file
if not file_dag_ids.issubset(readable_dag_ids):
error.stacktrace = REDACTED_STACKTRACE
return error
@@ -152,11 +152,11 @@ def get_import_errors(
auth_manager = get_auth_manager()
readable_dag_ids = auth_manager.get_authorized_dag_ids(method="GET",
user=user)
- # Subquery for files that have any DAGs
+ # Subquery for files that have any Dags
files_with_any_dags =
select(DagModel.relative_fileloc).distinct().subquery()
# Files (identified by ``(relative_fileloc, bundle_name)``) where the
- # user can read at least one DAG. Used to decide which import errors
+ # user can read at least one Dag. Used to decide which import errors
# the user is allowed to see at all.
readable_files_cte = (
select(DagModel.relative_fileloc, DagModel.bundle_name)
@@ -166,10 +166,10 @@ def get_import_errors(
)
# Full ``(relative_fileloc, dag_id, bundle_name)`` set for every file
- # the user can see at least one DAG of. Crucially this is **not**
+ # the user can see at least one Dag of. Crucially this is **not**
# filtered by ``readable_dag_ids`` -- the per-file authorization
- # check in the loop below needs the complete DAG set so it can
- # detect co-located DAGs that the caller is not authorized to read
+ # check in the loop below needs the complete Dag set so it can
+ # detect co-located Dags that the caller is not authorized to read
# and redact the stacktrace accordingly.
file_dags_cte = (
select(DagModel.relative_fileloc, DagModel.dag_id,
DagModel.bundle_name)
@@ -185,8 +185,8 @@ def get_import_errors(
# Prepare the import errors query by joining with the CTE above.
# Each returned row will be a tuple: (ParseImportError, dag_id).
- # ``dag_id`` is NULL for import errors whose file has no DAGs at all
- # in ``DagModel`` (parse failed before any DAG was defined).
+ # ``dag_id`` is NULL for import errors whose file has no Dags at all
+ # in ``DagModel`` (parse failed before any Dag was defined).
import_errors_stmt = (
select(ParseImportError, file_dags_cte.c.dag_id)
.outerjoin(
@@ -226,8 +226,8 @@ def get_import_errors(
for import_error, file_dag_ids_iter in import_errors_result:
dag_ids = [dag_id for _, dag_id in file_dag_ids_iter if dag_id is not
None]
- # No DAGs matched for this file -- either the file genuinely has
- # no DAGs yet (parse failed before any DAG was defined), or the
+ # No Dags matched for this file -- either the file genuinely has
+ # no Dags yet (parse failed before any Dag was defined), or the
# name keys did not resolve. Redact the stacktrace before
# appending so the response stays on the deny-by-default side of
# the authorization check.
@@ -238,7 +238,7 @@ def get_import_errors(
continue
dag_id_to_team = DagModel.get_dag_id_to_team_name_mapping(dag_ids,
session=session)
- # Check if user has read access to all the DAGs defined in the file
+ # Check if user has read access to all the Dags defined in the file
requests: Sequence[IsAuthorizedDagRequest] = [
{
"method": "GET",
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
index 228e787616e..fe4012662db 100644
---
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
+++
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
@@ -511,7 +511,7 @@ def get_task_instances(
Get list of task instances.
This endpoint allows specifying `~` as the dag_id, dag_run_id
- to retrieve task instances for all DAGs and DAG runs.
+ to retrieve task instances for all Dags and Dag runs.
Supports two pagination modes:
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/tasks.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/tasks.py
index 2df27b682ea..0f95d2fc401 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/tasks.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/tasks.py
@@ -72,7 +72,7 @@ def get_tasks(
session: SessionDep,
order_by: str = "task_id",
) -> TaskCollectionResponse:
- """Get tasks for DAG."""
+ """Get tasks for Dag."""
dag = get_latest_version_of_dag(dag_bag, dag_id, session)
lstripped_order_by = order_by.lstrip("-")
if lstripped_order_by not in _SORTABLE_TASK_FIELDS:
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
index 8845d79a72f..2d98d873278 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
@@ -187,7 +187,7 @@ def get_xcom_entries(
"""
Get all XCom entries.
- This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all DAGs.
+ This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all Dags.
"""
query = select(XComModel)
if dag_id != "~":
@@ -257,7 +257,7 @@ def create_xcom_entry(
from airflow.models.dagrun import DagRun
dag_run = session.scalar(select(DagRun).where(DagRun.dag_id == dag_id,
DagRun.run_id == dag_run_id))
- # Validate DAG ID
+ # Validate Dag ID
dag = get_dag_for_run_or_latest_version(dag_bag, dag_run, dag_id, session)
# Validate Task ID
@@ -268,7 +268,7 @@ def create_xcom_entry(
status.HTTP_404_NOT_FOUND, f"Task with ID: `{task_id}` not found
in dag: `{dag_id}`"
)
- # Validate DAG Run ID
+ # Validate Dag Run ID
if not dag_run:
if not dag_run:
raise HTTPException(
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 72f51490f12..a1896f0c23f 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
@@ -124,7 +124,7 @@ def get_dags(
user: GetUserDep,
dag_runs_limit: int = 10,
) -> DAGWithLatestDagRunsCollectionResponse:
- """Get DAGs with recent DagRun."""
+ """Get Dags with recent DagRun."""
# Fetch Dags with their latest DagRun and apply filters
query = generate_dag_with_latest_run_query(
max_run_filters=[
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
b/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
index 1db92911eeb..ad225db6d03 100644
---
a/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
+++
b/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
@@ -64,7 +64,7 @@ def _patch_ti_validate_request(
) -> tuple[SerializedDAG, list[TI], dict]:
dag = get_latest_version_of_dag(dag_bag, dag_id, session)
if not dag.has_task(task_id):
- raise HTTPException(status.HTTP_404_NOT_FOUND, f"Task '{task_id}' not
found in DAG '{dag_id}'")
+ raise HTTPException(status.HTTP_404_NOT_FOUND, f"Task '{task_id}' not
found in Dag '{dag_id}'")
query = (
select(TI)
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/calendar.py
b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/calendar.py
index 2369199f0fe..ebd5a38453e 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/calendar.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/calendar.py
@@ -57,12 +57,12 @@ class CalendarService:
granularity: Literal["hourly", "daily"] = "daily",
) -> CalendarTimeRangeCollectionResponse:
"""
- Get calendar data for a DAG including historical and planned runs.
+ Get calendar data for a Dag including historical and planned runs.
Args:
- dag_id: The DAG ID
+ dag_id: The Dag ID
session: Database session
- dag: The DAG object
+ dag: The Dag object
logical_date: Date range filter for logical_date
partition_date: Date range filter for partition_date
granularity: Time granularity ("hourly" or "daily")
@@ -93,7 +93,7 @@ class CalendarService:
date_filter: RangeFilter,
granularity: Literal["hourly", "daily"],
) -> tuple[list[CalendarTimeRangeResponse], Sequence[Row]]:
- """Get historical DAG runs from the database."""
+ """Get historical Dag runs from the database."""
dialect = get_dialect_name(session)
effective_date = sa.func.coalesce(DagRun.partition_date,
DagRun.logical_date)
@@ -136,7 +136,7 @@ class CalendarService:
date_filter: RangeFilter,
granularity: Literal["hourly", "daily"],
) -> list[CalendarTimeRangeResponse]:
- """Get planned DAG runs based on the DAG's timetable."""
+ """Get planned Dag runs based on the Dag's timetable."""
if not self._should_calculate_planned_runs(dag, raw_dag_states):
return []
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/dependencies.py
b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/dependencies.py
index cedb18706b9..ead14c68a2d 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/dependencies.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/dependencies.py
@@ -85,7 +85,7 @@ def extract_single_connected_component(
def get_scheduling_dependencies(readable_dag_ids: set[str] | None = None) ->
dict[str, list[dict]]:
- """Get scheduling dependencies between DAGs."""
+ """Get scheduling dependencies between Dags."""
from airflow.models.serialized_dag import SerializedDagModel
nodes_dict: dict[str, dict] = {}
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/grid.py
b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/grid.py
index 4ee93f4f10e..838818ad66b 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/grid.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/grid.py
@@ -34,8 +34,8 @@ log = structlog.get_logger(logger_name=__name__)
def _merge_node_dicts(current: list[dict[str, Any]], new: list[dict[str, Any]]
| None) -> None:
- """Merge node dictionaries from different DAG versions, handling structure
changes."""
- # Handle None case - can occur when merging old DAG versions
+ """Merge node dictionaries from different Dag versions, handling structure
changes."""
+ # Handle None case - can occur when merging old Dag versions
# where a TaskGroup was converted to a task or vice versa
if new is None:
return
@@ -46,7 +46,7 @@ def _merge_node_dicts(current: list[dict[str, Any]], new:
list[dict[str, Any]] |
current_node = current_nodes_by_id.get(node_id)
if current_node is not None:
# Only merge children if current node already has children
- # This preserves the structure of the latest DAG version
+ # This preserves the structure of the latest Dag version
if current_node.get("children") is not None:
_merge_node_dicts(current_node["children"],
node.get("children"))
else:
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/task_group.py
b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/task_group.py
index a3aa51e319c..9c156c097aa 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/services/ui/task_group.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/services/ui/task_group.py
@@ -30,7 +30,7 @@ from airflow.serialization.definitions.mappedoperator import
SerializedMappedOpe
@cache
def get_task_group_children_getter() -> Callable:
- """Get the Task Group Children Getter for the DAG."""
+ """Get the Task Group Children Getter for the Dag."""
sort_order = conf.get("api", "grid_view_sorting_order")
if sort_order == "topological":
return methodcaller("topological_sort")
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 87b5d2296a6..b5145f1a689 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
@@ -132,7 +132,7 @@ export const ensureUseAssetServiceGetAssetData =
(queryClient: QueryClient, { as
}) => queryClient.ensureQueryData({ queryKey:
Common.UseAssetServiceGetAssetKeyFn({ assetId }), queryFn: () =>
AssetService.getAsset({ assetId }) });
/**
* Get Dag Asset Queued Events
-* Get queued asset events for a DAG.
+* Get queued asset events for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.before
@@ -145,7 +145,7 @@ export const
ensureUseAssetServiceGetDagAssetQueuedEventsData = (queryClient: Qu
}) => queryClient.ensureQueryData({ queryKey:
Common.UseAssetServiceGetDagAssetQueuedEventsKeyFn({ before, dagId }), queryFn:
() => AssetService.getDagAssetQueuedEvents({ before, dagId }) });
/**
* Get Dag Asset Queued Event
-* Get a queued asset event for a DAG.
+* Get a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -278,9 +278,9 @@ export const
ensureUseDagRunServiceGetUpstreamAssetEventsData = (queryClient: Qu
}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagRunServiceGetUpstreamAssetEventsKeyFn({ dagId, dagRunId }),
queryFn: () => DagRunService.getUpstreamAssetEvents({ dagId, dagRunId }) });
/**
* Get Dag Runs
-* Get all DAG Runs.
+* Get all Dag Runs.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all Dags.
*
* Supports two pagination modes:
*
@@ -392,7 +392,7 @@ export const ensureUseDagRunServiceGetDagRunsData =
(queryClient: QueryClient, {
}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagRunServiceGetDagRunsKeyFn({ bundleVersion, confContains,
consumingAssetPattern, cursor, dagId, dagIdPattern, dagIdPrefixPattern,
dagVersion, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, offset, orderBy, partitionKeyPattern,
partitionKeyPrefixPattern, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
runIdPattern [...]
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -409,7 +409,7 @@ export const
ensureUseDagRunServiceWaitDagRunUntilFinishedData = (queryClient: Q
}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagRunServiceWaitDagRunUntilFinishedKeyFn({ dagId, dagRunId,
interval, result }), queryFn: () => DagRunService.waitDagRunUntilFinished({
dagId, dagRunId, interval, result }) });
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -504,7 +504,7 @@ export const ensureUseDagWarningServiceListDagWarningsData
= (queryClient: Query
} = {}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagWarningServiceListDagWarningsKeyFn({ dagId, limit, offset,
orderBy, warningType }), queryFn: () => DagWarningService.listDagWarnings({
dagId, limit, offset, orderBy, warningType }) });
/**
* Get Dags
-* Get all DAGs.
+* Get all Dags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -575,7 +575,7 @@ export const ensureUseDagServiceGetDagsData = (queryClient:
QueryClient, { asset
} = {}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagServiceGetDagsKeyFn({ assetDependency, bundleName, bundleVersion,
dagDisplayNamePattern, dagDisplayNamePrefixPattern, dagIdPattern,
dagIdPrefixPattern, dagRunEndDateGt, dagRunEndDateGte, dagRunEndDateLt,
dagRunEndDateLte, dagRunStartDateGt, dagRunStartDateGte, dagRunStartDateLt,
dagRunStartDateLte, dagRunState, excludeStale, hasAssetSchedule,
hasImportErrors, isFavorite, lastDagRunState, limit, offset, orderBy, owners,
pause [...]
/**
* Get Dag
-* Get basic information about a DAG.
+* Get basic information about a Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGResponse Successful Response
@@ -586,7 +586,7 @@ export const ensureUseDagServiceGetDagData = (queryClient:
QueryClient, { dagId
}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagServiceGetDagKeyFn({ dagId }), queryFn: () => DagService.getDag({
dagId }) });
/**
* Get Dag Details
-* Get details of DAG.
+* Get details of Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGDetailsResponse Successful Response
@@ -597,7 +597,7 @@ export const ensureUseDagServiceGetDagDetailsData =
(queryClient: QueryClient, {
}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagServiceGetDagDetailsKeyFn({ dagId }), queryFn: () =>
DagService.getDagDetails({ dagId }) });
/**
* Get Dag Tags
-* Get all DAG tags.
+* Get all Dag tags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -618,7 +618,7 @@ export const ensureUseDagServiceGetDagTagsData =
(queryClient: QueryClient, { li
} = {}) => queryClient.ensureQueryData({ queryKey:
Common.UseDagServiceGetDagTagsKeyFn({ limit, offset, orderBy, tagNamePattern,
tagNamePrefixPattern }), queryFn: () => DagService.getDagTags({ limit, offset,
orderBy, tagNamePattern, tagNamePrefixPattern }) });
/**
* Get Dags
-* Get DAGs with recent DagRun.
+* Get Dags with recent DagRun.
* @param data The data for the request.
* @param data.dagRunsLimit
* @param data.limit
@@ -1006,7 +1006,7 @@ export const
ensureUseTaskInstanceServiceGetMappedTaskInstanceData = (queryClien
* Get list of task instances.
*
* This endpoint allows specifying `~` as the dag_id, dag_run_id
-* to retrieve task instances for all DAGs and DAG runs.
+* to retrieve task instances for all Dags and Dag runs.
*
* Supports two pagination modes:
*
@@ -1477,7 +1477,7 @@ export const ensureUseXcomServiceGetXcomEntryData =
(queryClient: QueryClient, {
* Get Xcom Entries
* Get all XCom entries.
*
-* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all DAGs.
+* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1544,7 +1544,7 @@ export const ensureUseXcomServiceGetXcomEntriesData =
(queryClient: QueryClient,
}) => queryClient.ensureQueryData({ queryKey:
Common.UseXcomServiceGetXcomEntriesKeyFn({ dagDisplayNamePattern,
dagDisplayNamePrefixPattern, dagId, dagRunId, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, mapIndexFilter,
offset, orderBy, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
runIdPattern, runIdPrefixPattern, taskId, taskIdPattern, taskIdPrefixPattern,
xcomKey, xcomKeyPattern, xcomKeyPrefixPattern }), queryFn: () =>
XcomService.getXcomEntries({ [...]
/**
* Get Tasks
-* Get tasks for DAG.
+* Get tasks for Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.orderBy
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 e1a9b60682f..e3b86491719 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
@@ -132,7 +132,7 @@ export const prefetchUseAssetServiceGetAsset =
(queryClient: QueryClient, { asse
}) => queryClient.prefetchQuery({ queryKey:
Common.UseAssetServiceGetAssetKeyFn({ assetId }), queryFn: () =>
AssetService.getAsset({ assetId }) });
/**
* Get Dag Asset Queued Events
-* Get queued asset events for a DAG.
+* Get queued asset events for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.before
@@ -145,7 +145,7 @@ export const prefetchUseAssetServiceGetDagAssetQueuedEvents
= (queryClient: Quer
}) => queryClient.prefetchQuery({ queryKey:
Common.UseAssetServiceGetDagAssetQueuedEventsKeyFn({ before, dagId }), queryFn:
() => AssetService.getDagAssetQueuedEvents({ before, dagId }) });
/**
* Get Dag Asset Queued Event
-* Get a queued asset event for a DAG.
+* Get a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -278,9 +278,9 @@ export const prefetchUseDagRunServiceGetUpstreamAssetEvents
= (queryClient: Quer
}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagRunServiceGetUpstreamAssetEventsKeyFn({ dagId, dagRunId }),
queryFn: () => DagRunService.getUpstreamAssetEvents({ dagId, dagRunId }) });
/**
* Get Dag Runs
-* Get all DAG Runs.
+* Get all Dag Runs.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all Dags.
*
* Supports two pagination modes:
*
@@ -392,7 +392,7 @@ export const prefetchUseDagRunServiceGetDagRuns =
(queryClient: QueryClient, { b
}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagRunServiceGetDagRunsKeyFn({ bundleVersion, confContains,
consumingAssetPattern, cursor, dagId, dagIdPattern, dagIdPrefixPattern,
dagVersion, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, offset, orderBy, partitionKeyPattern,
partitionKeyPrefixPattern, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
runIdPattern, [...]
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -409,7 +409,7 @@ export const
prefetchUseDagRunServiceWaitDagRunUntilFinished = (queryClient: Que
}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagRunServiceWaitDagRunUntilFinishedKeyFn({ dagId, dagRunId,
interval, result }), queryFn: () => DagRunService.waitDagRunUntilFinished({
dagId, dagRunId, interval, result }) });
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -504,7 +504,7 @@ export const prefetchUseDagWarningServiceListDagWarnings =
(queryClient: QueryCl
} = {}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagWarningServiceListDagWarningsKeyFn({ dagId, limit, offset,
orderBy, warningType }), queryFn: () => DagWarningService.listDagWarnings({
dagId, limit, offset, orderBy, warningType }) });
/**
* Get Dags
-* Get all DAGs.
+* Get all Dags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -575,7 +575,7 @@ export const prefetchUseDagServiceGetDags = (queryClient:
QueryClient, { assetDe
} = {}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagServiceGetDagsKeyFn({ assetDependency, bundleName, bundleVersion,
dagDisplayNamePattern, dagDisplayNamePrefixPattern, dagIdPattern,
dagIdPrefixPattern, dagRunEndDateGt, dagRunEndDateGte, dagRunEndDateLt,
dagRunEndDateLte, dagRunStartDateGt, dagRunStartDateGte, dagRunStartDateLt,
dagRunStartDateLte, dagRunState, excludeStale, hasAssetSchedule,
hasImportErrors, isFavorite, lastDagRunState, limit, offset, orderBy, owners,
paused, [...]
/**
* Get Dag
-* Get basic information about a DAG.
+* Get basic information about a Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGResponse Successful Response
@@ -586,7 +586,7 @@ export const prefetchUseDagServiceGetDag = (queryClient:
QueryClient, { dagId }:
}) => queryClient.prefetchQuery({ queryKey: Common.UseDagServiceGetDagKeyFn({
dagId }), queryFn: () => DagService.getDag({ dagId }) });
/**
* Get Dag Details
-* Get details of DAG.
+* Get details of Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGDetailsResponse Successful Response
@@ -597,7 +597,7 @@ export const prefetchUseDagServiceGetDagDetails =
(queryClient: QueryClient, { d
}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagServiceGetDagDetailsKeyFn({ dagId }), queryFn: () =>
DagService.getDagDetails({ dagId }) });
/**
* Get Dag Tags
-* Get all DAG tags.
+* Get all Dag tags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -618,7 +618,7 @@ export const prefetchUseDagServiceGetDagTags =
(queryClient: QueryClient, { limi
} = {}) => queryClient.prefetchQuery({ queryKey:
Common.UseDagServiceGetDagTagsKeyFn({ limit, offset, orderBy, tagNamePattern,
tagNamePrefixPattern }), queryFn: () => DagService.getDagTags({ limit, offset,
orderBy, tagNamePattern, tagNamePrefixPattern }) });
/**
* Get Dags
-* Get DAGs with recent DagRun.
+* Get Dags with recent DagRun.
* @param data The data for the request.
* @param data.dagRunsLimit
* @param data.limit
@@ -1006,7 +1006,7 @@ export const
prefetchUseTaskInstanceServiceGetMappedTaskInstance = (queryClient:
* Get list of task instances.
*
* This endpoint allows specifying `~` as the dag_id, dag_run_id
-* to retrieve task instances for all DAGs and DAG runs.
+* to retrieve task instances for all Dags and Dag runs.
*
* Supports two pagination modes:
*
@@ -1477,7 +1477,7 @@ export const prefetchUseXcomServiceGetXcomEntry =
(queryClient: QueryClient, { d
* Get Xcom Entries
* Get all XCom entries.
*
-* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all DAGs.
+* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1544,7 +1544,7 @@ export const prefetchUseXcomServiceGetXcomEntries =
(queryClient: QueryClient, {
}) => queryClient.prefetchQuery({ queryKey:
Common.UseXcomServiceGetXcomEntriesKeyFn({ dagDisplayNamePattern,
dagDisplayNamePrefixPattern, dagId, dagRunId, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, mapIndexFilter,
offset, orderBy, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
runIdPattern, runIdPrefixPattern, taskId, taskIdPattern, taskIdPrefixPattern,
xcomKey, xcomKeyPattern, xcomKeyPrefixPattern }), queryFn: () =>
XcomService.getXcomEntries({ da [...]
/**
* Get Tasks
-* Get tasks for DAG.
+* Get tasks for Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.orderBy
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 c5c4cc23665..214782599bd 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
@@ -132,7 +132,7 @@ export const useAssetServiceGetAsset = <TData =
Common.AssetServiceGetAssetDefau
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseAssetServiceGetAssetKeyFn({ assetId }, queryKey), queryFn: () =>
AssetService.getAsset({ assetId }) as TData, ...options });
/**
* Get Dag Asset Queued Events
-* Get queued asset events for a DAG.
+* Get queued asset events for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.before
@@ -145,7 +145,7 @@ export const useAssetServiceGetDagAssetQueuedEvents =
<TData = Common.AssetServi
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseAssetServiceGetDagAssetQueuedEventsKeyFn({ before, dagId },
queryKey), queryFn: () => AssetService.getDagAssetQueuedEvents({ before, dagId
}) as TData, ...options });
/**
* Get Dag Asset Queued Event
-* Get a queued asset event for a DAG.
+* Get a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -278,9 +278,9 @@ export const useDagRunServiceGetUpstreamAssetEvents =
<TData = Common.DagRunServ
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagRunServiceGetUpstreamAssetEventsKeyFn({ dagId, dagRunId },
queryKey), queryFn: () => DagRunService.getUpstreamAssetEvents({ dagId,
dagRunId }) as TData, ...options });
/**
* Get Dag Runs
-* Get all DAG Runs.
+* Get all Dag Runs.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all Dags.
*
* Supports two pagination modes:
*
@@ -392,7 +392,7 @@ export const useDagRunServiceGetDagRuns = <TData =
Common.DagRunServiceGetDagRun
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagRunServiceGetDagRunsKeyFn({ bundleVersion, confContains,
consumingAssetPattern, cursor, dagId, dagIdPattern, dagIdPrefixPattern,
dagVersion, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, offset, orderBy, partitionKeyPattern, [...]
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -409,7 +409,7 @@ export const useDagRunServiceWaitDagRunUntilFinished =
<TData = Common.DagRunSer
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagRunServiceWaitDagRunUntilFinishedKeyFn({ dagId, dagRunId,
interval, result }, queryKey), queryFn: () =>
DagRunService.waitDagRunUntilFinished({ dagId, dagRunId, interval, result }) as
TData, ...options });
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -504,7 +504,7 @@ export const useDagWarningServiceListDagWarnings = <TData =
Common.DagWarningSer
} = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagWarningServiceListDagWarningsKeyFn({ dagId, limit, offset,
orderBy, warningType }, queryKey), queryFn: () =>
DagWarningService.listDagWarnings({ dagId, limit, offset, orderBy, warningType
}) as TData, ...options });
/**
* Get Dags
-* Get all DAGs.
+* Get all Dags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -575,7 +575,7 @@ export const useDagServiceGetDags = <TData =
Common.DagServiceGetDagsDefaultResp
} = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagsKeyFn({ assetDependency, bundleName, bundleVersion,
dagDisplayNamePattern, dagDisplayNamePrefixPattern, dagIdPattern,
dagIdPrefixPattern, dagRunEndDateGt, dagRunEndDateGte, dagRunEndDateLt,
dagRunEndDateLte, dagRunStartDateGt, dagRunStartDateGte, dagRunStartDateLt,
dagRunStartDateLte, dagRunState, excludeStale, hasAssetSch [...]
/**
* Get Dag
-* Get basic information about a DAG.
+* Get basic information about a Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGResponse Successful Response
@@ -586,7 +586,7 @@ export const useDagServiceGetDag = <TData =
Common.DagServiceGetDagDefaultRespon
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagKeyFn({ dagId }, queryKey), queryFn: () =>
DagService.getDag({ dagId }) as TData, ...options });
/**
* Get Dag Details
-* Get details of DAG.
+* Get details of Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGDetailsResponse Successful Response
@@ -597,7 +597,7 @@ export const useDagServiceGetDagDetails = <TData =
Common.DagServiceGetDagDetail
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagDetailsKeyFn({ dagId }, queryKey), queryFn: () =>
DagService.getDagDetails({ dagId }) as TData, ...options });
/**
* Get Dag Tags
-* Get all DAG tags.
+* Get all Dag tags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -618,7 +618,7 @@ export const useDagServiceGetDagTags = <TData =
Common.DagServiceGetDagTagsDefau
} = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagTagsKeyFn({ limit, offset, orderBy, tagNamePattern,
tagNamePrefixPattern }, queryKey), queryFn: () => DagService.getDagTags({
limit, offset, orderBy, tagNamePattern, tagNamePrefixPattern }) as TData,
...options });
/**
* Get Dags
-* Get DAGs with recent DagRun.
+* Get Dags with recent DagRun.
* @param data The data for the request.
* @param data.dagRunsLimit
* @param data.limit
@@ -1006,7 +1006,7 @@ export const useTaskInstanceServiceGetMappedTaskInstance
= <TData = Common.TaskI
* Get list of task instances.
*
* This endpoint allows specifying `~` as the dag_id, dag_run_id
-* to retrieve task instances for all DAGs and DAG runs.
+* to retrieve task instances for all Dags and Dag runs.
*
* Supports two pagination modes:
*
@@ -1477,7 +1477,7 @@ export const useXcomServiceGetXcomEntry = <TData =
Common.XcomServiceGetXcomEntr
* Get Xcom Entries
* Get all XCom entries.
*
-* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all DAGs.
+* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1544,7 +1544,7 @@ export const useXcomServiceGetXcomEntries = <TData =
Common.XcomServiceGetXcomEn
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseXcomServiceGetXcomEntriesKeyFn({ dagDisplayNamePattern,
dagDisplayNamePrefixPattern, dagId, dagRunId, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, mapIndexFilter,
offset, orderBy, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
runIdPattern, runIdPrefixPattern, taskId, taskIdPattern, taskIdPrefixPattern,
xcom [...]
/**
* Get Tasks
-* Get tasks for DAG.
+* Get tasks for Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.orderBy
@@ -1953,7 +1953,7 @@ export const useAssetServiceCreateAssetEvent = <TData =
Common.AssetServiceCreat
}, TContext>({ mutationFn: ({ requestBody }) =>
AssetService.createAssetEvent({ requestBody }) as unknown as Promise<TData>,
...options });
/**
* Materialize Asset
-* Materialize an asset by triggering a DAG run that produces it.
+* Materialize an asset by triggering a Dag run that produces it.
* @param data The data for the request.
* @param data.assetId
* @param data.requestBody
@@ -2048,7 +2048,7 @@ export const useDagRunServiceClearDagRun = <TData =
Common.DagRunServiceClearDag
}, TContext>({ mutationFn: ({ dagId, dagRunId, requestBody }) =>
DagRunService.clearDagRun({ dagId, dagRunId, requestBody }) as unknown as
Promise<TData>, ...options });
/**
* Trigger Dag Run
-* Trigger a DAG.
+* Trigger a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.requestBody
@@ -2064,7 +2064,7 @@ export const useDagRunServiceTriggerDagRun = <TData =
Common.DagRunServiceTrigge
}, TContext>({ mutationFn: ({ dagId, requestBody }) =>
DagRunService.triggerDagRun({ dagId, requestBody }) as unknown as
Promise<TData>, ...options });
/**
* Get List Dag Runs Batch
-* Get a list of DAG Runs.
+* Get a list of Dag Runs.
* @param data The data for the request.
* @param data.dagId
* @param data.requestBody
@@ -2080,7 +2080,7 @@ export const useDagRunServiceGetListDagRunsBatch = <TData
= Common.DagRunService
}, TContext>({ mutationFn: ({ dagId, requestBody }) =>
DagRunService.getListDagRunsBatch({ dagId, requestBody }) as unknown as
Promise<TData>, ...options });
/**
* Favorite Dag
-* Mark the DAG as favorite.
+* Mark the Dag as favorite.
* @param data The data for the request.
* @param data.dagId
* @returns void Successful Response
@@ -2093,7 +2093,7 @@ export const useDagServiceFavoriteDag = <TData =
Common.DagServiceFavoriteDagMut
}, TContext>({ mutationFn: ({ dagId }) => DagService.favoriteDag({ dagId }) as
unknown as Promise<TData>, ...options });
/**
* Unfavorite Dag
-* Unmark the DAG as favorite.
+* Unmark the Dag as favorite.
* @param data The data for the request.
* @param data.dagId
* @returns void Successful Response
@@ -2238,7 +2238,7 @@ export const useBackfillServiceCancelBackfill = <TData =
Common.BackfillServiceC
}, TContext>({ mutationFn: ({ backfillId }) =>
BackfillService.cancelBackfill({ backfillId }) as unknown as Promise<TData>,
...options });
/**
* Reparse Dag File
-* Request re-parsing a DAG file.
+* Request re-parsing a Dag file.
* @param data The data for the request.
* @param data.fileToken
* @returns unknown Successful Response
@@ -2283,7 +2283,7 @@ export const useConnectionServiceBulkConnections = <TData
= Common.ConnectionSer
}, TContext>({ mutationFn: ({ requestBody }) =>
ConnectionService.bulkConnections({ requestBody }) as unknown as
Promise<TData>, ...options });
/**
* Patch Dag Run
-* Modify a DAG Run.
+* Modify a Dag Run.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -2305,10 +2305,10 @@ export const useDagRunServicePatchDagRun = <TData =
Common.DagRunServicePatchDag
}, TContext>({ mutationFn: ({ dagId, dagRunId, requestBody, updateMask }) =>
DagRunService.patchDagRun({ dagId, dagRunId, requestBody, updateMask }) as
unknown as Promise<TData>, ...options });
/**
* Patch Dags
-* Patch multiple DAGs.
+* Patch multiple Dags.
*
-* If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided, no DAGs
will be
-* matched regardless of other filters. To match all DAGs, pass a wildcard
value such as
+* If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided, no Dags
will be
+* matched regardless of other filters. To match all Dags, pass a wildcard
value such as
* `~` or `%` for `dag_id_pattern`.
* @param data The data for the request.
* @param data.requestBody
@@ -2354,7 +2354,7 @@ export const useDagServicePatchDags = <TData =
Common.DagServicePatchDagsMutatio
}, TContext>({ mutationFn: ({ dagIdPattern, dagIdPrefixPattern, excludeStale,
limit, offset, owners, paused, requestBody, tags, tagsMatchMode, updateMask })
=> DagService.patchDags({ dagIdPattern, dagIdPrefixPattern, excludeStale,
limit, offset, owners, paused, requestBody, tags, tagsMatchMode, updateMask })
as unknown as Promise<TData>, ...options });
/**
* Patch Dag
-* Patch the specific DAG.
+* Patch the specific Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.requestBody
@@ -2649,7 +2649,7 @@ export const useAssetServiceDeleteDagAssetQueuedEvents =
<TData = Common.AssetSe
}, TContext>({ mutationFn: ({ before, dagId }) =>
AssetService.deleteDagAssetQueuedEvents({ before, dagId }) as unknown as
Promise<TData>, ...options });
/**
* Delete Dag Asset Queued Event
-* Delete a queued asset event for a DAG.
+* Delete a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -2681,7 +2681,7 @@ export const useConnectionServiceDeleteConnection =
<TData = Common.ConnectionSe
}, TContext>({ mutationFn: ({ connectionId }) =>
ConnectionService.deleteConnection({ connectionId }) as unknown as
Promise<TData>, ...options });
/**
* Delete Dag Run
-* Delete a DAG Run entry.
+* Delete a Dag Run entry.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -2697,7 +2697,7 @@ export const useDagRunServiceDeleteDagRun = <TData =
Common.DagRunServiceDeleteD
}, TContext>({ mutationFn: ({ dagId, dagRunId }) =>
DagRunService.deleteDagRun({ dagId, dagRunId }) as unknown as Promise<TData>,
...options });
/**
* Delete Dag
-* Delete the specific DAG.
+* Delete the specific Dag.
* @param data The data for the request.
* @param data.dagId
* @returns unknown Successful Response
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 056a6451f9a..a3d55ea6a33 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
@@ -132,7 +132,7 @@ export const useAssetServiceGetAssetSuspense = <TData =
Common.AssetServiceGetAs
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseAssetServiceGetAssetKeyFn({ assetId }, queryKey), queryFn: () =>
AssetService.getAsset({ assetId }) as TData, ...options });
/**
* Get Dag Asset Queued Events
-* Get queued asset events for a DAG.
+* Get queued asset events for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.before
@@ -145,7 +145,7 @@ export const useAssetServiceGetDagAssetQueuedEventsSuspense
= <TData = Common.As
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseAssetServiceGetDagAssetQueuedEventsKeyFn({ before, dagId },
queryKey), queryFn: () => AssetService.getDagAssetQueuedEvents({ before, dagId
}) as TData, ...options });
/**
* Get Dag Asset Queued Event
-* Get a queued asset event for a DAG.
+* Get a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -278,9 +278,9 @@ export const useDagRunServiceGetUpstreamAssetEventsSuspense
= <TData = Common.Da
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagRunServiceGetUpstreamAssetEventsKeyFn({ dagId, dagRunId },
queryKey), queryFn: () => DagRunService.getUpstreamAssetEvents({ dagId,
dagRunId }) as TData, ...options });
/**
* Get Dag Runs
-* Get all DAG Runs.
+* Get all Dag Runs.
*
-* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all DAGs.
+* This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs for
all Dags.
*
* Supports two pagination modes:
*
@@ -392,7 +392,7 @@ export const useDagRunServiceGetDagRunsSuspense = <TData =
Common.DagRunServiceG
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagRunServiceGetDagRunsKeyFn({ bundleVersion, confContains,
consumingAssetPattern, cursor, dagId, dagIdPattern, dagIdPrefixPattern,
dagVersion, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, offset, orderBy, partitionKey [...]
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -409,7 +409,7 @@ export const
useDagRunServiceWaitDagRunUntilFinishedSuspense = <TData = Common.D
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagRunServiceWaitDagRunUntilFinishedKeyFn({ dagId, dagRunId,
interval, result }, queryKey), queryFn: () =>
DagRunService.waitDagRunUntilFinished({ dagId, dagRunId, interval, result }) as
TData, ...options });
/**
* Experimental: Wait for a dag run to complete, and return task results if
requested.
-* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+* 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -504,7 +504,7 @@ export const useDagWarningServiceListDagWarningsSuspense =
<TData = Common.DagWa
} = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagWarningServiceListDagWarningsKeyFn({ dagId, limit, offset,
orderBy, warningType }, queryKey), queryFn: () =>
DagWarningService.listDagWarnings({ dagId, limit, offset, orderBy, warningType
}) as TData, ...options });
/**
* Get Dags
-* Get all DAGs.
+* Get all Dags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -575,7 +575,7 @@ export const useDagServiceGetDagsSuspense = <TData =
Common.DagServiceGetDagsDef
} = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagsKeyFn({ assetDependency, bundleName, bundleVersion,
dagDisplayNamePattern, dagDisplayNamePrefixPattern, dagIdPattern,
dagIdPrefixPattern, dagRunEndDateGt, dagRunEndDateGte, dagRunEndDateLt,
dagRunEndDateLte, dagRunStartDateGt, dagRunStartDateGte, dagRunStartDateLt,
dagRunStartDateLte, dagRunState, excludeStale, has [...]
/**
* Get Dag
-* Get basic information about a DAG.
+* Get basic information about a Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGResponse Successful Response
@@ -586,7 +586,7 @@ export const useDagServiceGetDagSuspense = <TData =
Common.DagServiceGetDagDefau
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagKeyFn({ dagId }, queryKey), queryFn: () =>
DagService.getDag({ dagId }) as TData, ...options });
/**
* Get Dag Details
-* Get details of DAG.
+* Get details of Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGDetailsResponse Successful Response
@@ -597,7 +597,7 @@ export const useDagServiceGetDagDetailsSuspense = <TData =
Common.DagServiceGetD
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagDetailsKeyFn({ dagId }, queryKey), queryFn: () =>
DagService.getDagDetails({ dagId }) as TData, ...options });
/**
* Get Dag Tags
-* Get all DAG tags.
+* Get all Dag tags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -618,7 +618,7 @@ export const useDagServiceGetDagTagsSuspense = <TData =
Common.DagServiceGetDagT
} = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseDagServiceGetDagTagsKeyFn({ limit, offset, orderBy, tagNamePattern,
tagNamePrefixPattern }, queryKey), queryFn: () => DagService.getDagTags({
limit, offset, orderBy, tagNamePattern, tagNamePrefixPattern }) as TData,
...options });
/**
* Get Dags
-* Get DAGs with recent DagRun.
+* Get Dags with recent DagRun.
* @param data The data for the request.
* @param data.dagRunsLimit
* @param data.limit
@@ -1006,7 +1006,7 @@ export const
useTaskInstanceServiceGetMappedTaskInstanceSuspense = <TData = Comm
* Get list of task instances.
*
* This endpoint allows specifying `~` as the dag_id, dag_run_id
-* to retrieve task instances for all DAGs and DAG runs.
+* to retrieve task instances for all Dags and Dag runs.
*
* Supports two pagination modes:
*
@@ -1477,7 +1477,7 @@ export const useXcomServiceGetXcomEntrySuspense = <TData
= Common.XcomServiceGet
* Get Xcom Entries
* Get all XCom entries.
*
-* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all DAGs.
+* This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to
retrieve XCom entries for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1544,7 +1544,7 @@ export const useXcomServiceGetXcomEntriesSuspense =
<TData = Common.XcomServiceG
}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseXcomServiceGetXcomEntriesKeyFn({ dagDisplayNamePattern,
dagDisplayNamePrefixPattern, dagId, dagRunId, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, mapIndexFilter,
offset, orderBy, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
runIdPattern, runIdPrefixPattern, taskId, taskIdPattern, taskIdPrefixPatte [...]
/**
* Get Tasks
-* Get tasks for DAG.
+* Get tasks for Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.orderBy
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 c2f71f1ea0f..3fabd5ebf59 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
@@ -185,7 +185,7 @@ export class AssetService {
/**
* Materialize Asset
- * Materialize an asset by triggering a DAG run that produces it.
+ * Materialize an asset by triggering a Dag run that produces it.
* @param data The data for the request.
* @param data.assetId
* @param data.requestBody
@@ -293,7 +293,7 @@ export class AssetService {
/**
* Get Dag Asset Queued Events
- * Get queued asset events for a DAG.
+ * Get queued asset events for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.before
@@ -348,7 +348,7 @@ export class AssetService {
/**
* Get Dag Asset Queued Event
- * Get a queued asset event for a DAG.
+ * Get a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -378,7 +378,7 @@ export class AssetService {
/**
* Delete Dag Asset Queued Event
- * Delete a queued asset event for a DAG.
+ * Delete a queued asset event for a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.assetId
@@ -877,7 +877,7 @@ export class DagRunService {
/**
* Delete Dag Run
- * Delete a DAG Run entry.
+ * Delete a Dag Run entry.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -904,7 +904,7 @@ export class DagRunService {
/**
* Patch Dag Run
- * Modify a DAG Run.
+ * Modify a Dag Run.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -992,9 +992,9 @@ export class DagRunService {
/**
* Get Dag Runs
- * Get all DAG Runs.
+ * Get all Dag Runs.
*
- * This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs
for all DAGs.
+ * This endpoint allows specifying `~` as the dag_id to retrieve Dag Runs
for all Dags.
*
* Supports two pagination modes:
*
@@ -1121,7 +1121,7 @@ export class DagRunService {
/**
* Trigger Dag Run
- * Trigger a DAG.
+ * Trigger a Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.requestBody
@@ -1150,7 +1150,7 @@ export class DagRunService {
/**
* Experimental: Wait for a dag run to complete, and return task results
if requested.
- * 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+ * 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1182,7 +1182,7 @@ export class DagRunService {
/**
* Get List Dag Runs Batch
- * Get a list of DAG Runs.
+ * Get a list of Dag Runs.
* @param data The data for the request.
* @param data.dagId
* @param data.requestBody
@@ -1212,7 +1212,7 @@ export class DagRunService {
export class ExperimentalService {
/**
* Experimental: Wait for a dag run to complete, and return task results
if requested.
- * 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the DAG run state.
+ * 🚧 This is an experimental endpoint and may change or be removed without
notice.Successful response are streamed as newline-delimited JSON (NDJSON).
Each line is a JSON object representing the Dag run state.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -1423,7 +1423,7 @@ export class DagWarningService {
export class DagService {
/**
* Get Dags
- * Get all DAGs.
+ * Get all Dags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -1506,10 +1506,10 @@ export class DagService {
/**
* Patch Dags
- * Patch multiple DAGs.
+ * Patch multiple Dags.
*
- * If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided, no
DAGs will be
- * matched regardless of other filters. To match all DAGs, pass a wildcard
value such as
+ * If neither `dag_id_pattern` nor `dag_id_prefix_pattern` is provided, no
Dags will be
+ * matched regardless of other filters. To match all Dags, pass a wildcard
value such as
* `~` or `%` for `dag_id_pattern`.
* @param data The data for the request.
* @param data.requestBody
@@ -1558,7 +1558,7 @@ export class DagService {
/**
* Get Dag
- * Get basic information about a DAG.
+ * Get basic information about a Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGResponse Successful Response
@@ -1583,7 +1583,7 @@ export class DagService {
/**
* Patch Dag
- * Patch the specific DAG.
+ * Patch the specific Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.requestBody
@@ -1615,7 +1615,7 @@ export class DagService {
/**
* Delete Dag
- * Delete the specific DAG.
+ * Delete the specific Dag.
* @param data The data for the request.
* @param data.dagId
* @returns unknown Successful Response
@@ -1640,7 +1640,7 @@ export class DagService {
/**
* Get Dag Details
- * Get details of DAG.
+ * Get details of Dag.
* @param data The data for the request.
* @param data.dagId
* @returns DAGDetailsResponse Successful Response
@@ -1665,7 +1665,7 @@ export class DagService {
/**
* Favorite Dag
- * Mark the DAG as favorite.
+ * Mark the Dag as favorite.
* @param data The data for the request.
* @param data.dagId
* @returns void Successful Response
@@ -1689,7 +1689,7 @@ export class DagService {
/**
* Unfavorite Dag
- * Unmark the DAG as favorite.
+ * Unmark the Dag as favorite.
* @param data The data for the request.
* @param data.dagId
* @returns void Successful Response
@@ -1714,7 +1714,7 @@ export class DagService {
/**
* Get Dag Tags
- * Get all DAG tags.
+ * Get all Dag tags.
* @param data The data for the request.
* @param data.limit
* @param data.offset
@@ -1747,7 +1747,7 @@ export class DagService {
/**
* Get Dags
- * Get DAGs with recent DagRun.
+ * Get Dags with recent DagRun.
* @param data The data for the request.
* @param data.dagRunsLimit
* @param data.limit
@@ -2427,7 +2427,7 @@ export class TaskInstanceService {
* Get list of task instances.
*
* This endpoint allows specifying `~` as the dag_id, dag_run_id
- * to retrieve task instances for all DAGs and DAG runs.
+ * to retrieve task instances for all Dags and Dag runs.
*
* Supports two pagination modes:
*
@@ -3513,7 +3513,7 @@ export class XcomService {
* Get Xcom Entries
* Get all XCom entries.
*
- * This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id
to retrieve XCom entries for all DAGs.
+ * This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id
to retrieve XCom entries for all Dags.
* @param data The data for the request.
* @param data.dagId
* @param data.dagRunId
@@ -3631,7 +3631,7 @@ export class XcomService {
export class TaskService {
/**
* Get Tasks
- * Get tasks for DAG.
+ * Get tasks for Dag.
* @param data The data for the request.
* @param data.dagId
* @param data.orderBy
@@ -3851,7 +3851,7 @@ export class VariableService {
export class DagParsingService {
/**
* Reparse Dag File
- * Request re-parsing a DAG file.
+ * Request re-parsing a Dag file.
* @param data The data for the request.
* @param data.fileToken
* @returns unknown Successful Response
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
index f462a2ad034..26fe24888ac 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
@@ -1504,12 +1504,12 @@ class TestPostAssetMaterialize(TestAssets):
def test_should_respond_409_on_multiple_dags(self, test_client):
response = test_client.post("/assets/2/materialize")
assert response.status_code == 409
- assert response.json()["detail"] == "More than one DAG materializes
asset with ID: 2"
+ assert response.json()["detail"] == "More than one Dag materializes
asset with ID: 2"
def test_should_respond_404_on_multiple_dags(self, test_client):
response = test_client.post("/assets/3/materialize")
assert response.status_code == 404
- assert response.json()["detail"] == "No DAG materializes asset with
ID: 3"
+ assert response.json()["detail"] == "No Dag materializes asset with
ID: 3"
def test_should_respond_400_if_materialization_runs_denied(self,
test_client, session):
sdm = session.scalar(
@@ -1542,7 +1542,7 @@ class TestPostAssetMaterialize(TestAssets):
assert response.status_code == 403
assert response.json()["detail"] == (
- f"User is not authorized to trigger a run for DAG:
{self.DAG_ASSET1_ID} that materializes this asset"
+ f"User is not authorized to trigger a run for Dag:
{self.DAG_ASSET1_ID} that materializes this asset"
)
mock_get_auth_manager.return_value.is_authorized_dag.assert_called_once_with(
method="POST",
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
index e02484e2082..50dbf0190a4 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
@@ -2000,7 +2000,7 @@ class TestTriggerDagRun:
self._dags_for_trigger_tests(session)
response = test_client.post("/dags/inactive/dagRuns",
json={"logical_date": now})
assert response.status_code == 404
- assert response.json()["detail"] == "DAG with dag_id: 'inactive' not
found"
+ assert response.json()["detail"] == "Dag with dag_id: 'inactive' not
found"
def test_should_respond_400_if_a_dag_has_import_errors(self, test_client,
session, testing_dag_bundle):
now = timezone.utcnow().isoformat()
@@ -2009,7 +2009,7 @@ class TestTriggerDagRun:
assert response.status_code == 400
assert (
response.json()["detail"]
- == "DAG with dag_id: 'import_errors' has import errors and cannot
be triggered"
+ == "Dag with dag_id: 'import_errors' has import errors and cannot
be triggered"
)
def test_should_respond_400_if_manual_runs_denied(self, test_client,
session, testing_dag_bundle):
@@ -2106,7 +2106,7 @@ class TestTriggerDagRun:
now = timezone.utcnow().isoformat()
response = test_client.post("/dags/randoms/dagRuns",
json={"logical_date": now})
assert response.status_code == 404
- assert response.json()["detail"] == "DAG with dag_id: 'randoms' not
found"
+ assert response.json()["detail"] == "Dag with dag_id: 'randoms' not
found"
def test_response_409(self, test_client):
now = timezone.utcnow().isoformat()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
index ba0e0743697..d1321e71264 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
@@ -250,7 +250,7 @@ class TestGetImportError:
# Assert
mock_get_authorized_dag_ids.assert_called_once_with(user=mock.ANY)
assert response.status_code == 403
- assert response.json() == {"detail": "You do not have read permission
on any of the DAGs in the file"}
+ assert response.json() == {"detail": "You do not have read permission
on any of the Dags in the file"}
@mock.patch("airflow.api_fastapi.core_api.routes.public.import_error.get_auth_manager")
def
test_get_import_error__user_dont_have_read_permission_to_read_all_dags_in_file(
@@ -271,7 +271,7 @@ class TestGetImportError:
"import_error_id": import_error_id,
"timestamp": from_datetime_to_zulu_without_ms(TIMESTAMP1),
"filename": FILENAME1,
- "stack_trace": "REDACTED - you do not have read permission on all
DAGs in the file",
+ "stack_trace": "REDACTED - you do not have read permission on all
Dags in the file",
"bundle_name": BUNDLE_NAME,
}
@@ -425,7 +425,7 @@ class TestGetImportErrors:
pytest.param(
None,
False,
- "REDACTED - you do not have read permission on all DAGs in the
file",
+ "REDACTED - you do not have read permission on all Dags in the
file",
id="user_does_not_have_read_access_to_all_dags_in_current_file",
),
],
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
index 6c9bd417452..31f92e3c840 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
@@ -4563,7 +4563,7 @@ class TestPatchTaskInstance(TestTaskInstanceEndpoint):
)
assert response.status_code == 404
assert response.json() == {
- "detail": "Task 'non_existent_task' not found in DAG
'example_python_operator'"
+ "detail": "Task 'non_existent_task' not found in Dag
'example_python_operator'"
}
def test_should_raise_404_not_found_dag(self, test_client):
@@ -5332,7 +5332,7 @@ class
TestPatchTaskInstanceDryRun(TestTaskInstanceEndpoint):
)
assert response.status_code == 404
assert response.json() == {
- "detail": "Task 'non_existent_task' not found in DAG
'example_python_operator'"
+ "detail": "Task 'non_existent_task' not found in Dag
'example_python_operator'"
}
def test_should_raise_404_not_found_dag(self, test_client):
