You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ch...@apache.org on 2026/05/01 10:38:15 UTC
(airflow) branch main updated: Align Dag capitalization from "DAG" to "Dag" for airflow-ctl/ (#66112)
This is an automated email from the ASF dual-hosted git repository.
choo121600 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new fed3bfbaaa8 Align Dag capitalization from "DAG" to "Dag" for airflow-ctl/ (#66112)
fed3bfbaaa8 is described below
commit fed3bfbaaa88ae7e56caa3677d6fdd37cf9fffb2
Author: hojeong park <pa...@gmail.com>
AuthorDate: Fri May 1 19:38:07 2026 +0900
Align Dag capitalization from "DAG" to "Dag" for airflow-ctl/ (#66112)
* refactor: word changed from DAG to Dag in airflow-ctl/
* refactor: revert generated airflowctl datamodel changes
* refactor: word changed from DAG to Dag in airflow-core/src/airflow/api_fastapi/datamodels
generated files are included
---
.../api_fastapi/core_api/datamodels/assets.py | 2 +-
.../api_fastapi/core_api/datamodels/dag_run.py | 18 +--
.../api_fastapi/core_api/datamodels/dag_sources.py | 2 +-
.../api_fastapi/core_api/datamodels/dag_stats.py | 4 +-
.../api_fastapi/core_api/datamodels/dag_tags.py | 4 +-
.../core_api/datamodels/dag_versions.py | 2 +-
.../api_fastapi/core_api/datamodels/dag_warning.py | 4 +-
.../api_fastapi/core_api/datamodels/dags.py | 10 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 4 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 44 +++----
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 46 ++++----
.../airflow/ui/openapi-gen/requests/types.gen.ts | 46 ++++----
airflow-ctl/docs/howto/index.rst | 2 +-
airflow-ctl/docs/images/command_hashes.txt | 8 +-
airflow-ctl/docs/images/output_assets.svg | 128 ++++++++++-----------
airflow-ctl/docs/images/output_backfill.svg | 84 +++++++-------
airflow-ctl/docs/images/output_dagrun.svg | 60 +++++-----
airflow-ctl/docs/images/output_dags.svg | 116 +++++++++----------
airflow-ctl/src/airflowctl/api/client.py | 4 +-
.../src/airflowctl/api/datamodels/generated.py | 44 +++----
airflow-ctl/src/airflowctl/api/operations.py | 2 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 2 +-
.../src/airflowctl/ctl/commands/config_command.py | 4 +-
.../src/airflowctl/ctl/commands/dag_command.py | 6 +-
airflow-ctl/src/airflowctl/ctl/help_texts.yaml | 42 +++----
25 files changed, 344 insertions(+), 344 deletions(-)
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py
index 041ec12c1f2..f463f3ba5e3 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py
@@ -34,7 +34,7 @@ if TYPE_CHECKING:
class DagScheduleAssetReference(StrictBaseModel):
- """DAG schedule reference serializer for assets."""
+ """Dag schedule reference serializer for assets."""
dag_id: str
created_at: datetime
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py
index 8e5f31e09fa..481cc0387fe 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py
@@ -36,7 +36,7 @@ if TYPE_CHECKING:
class DAGRunPatchStates(str, Enum):
- """Enum for DAG Run states when updating a DAG Run."""
+ """Enum for Dag Run states when updating a Dag Run."""
QUEUED = DagRunState.QUEUED
SUCCESS = DagRunState.SUCCESS
@@ -44,20 +44,20 @@ class DAGRunPatchStates(str, Enum):
class DAGRunPatchBody(StrictBaseModel):
- """DAG Run Serializer for PATCH requests."""
+ """Dag Run Serializer for PATCH requests."""
state: DAGRunPatchStates | None = None
note: str | None = Field(None, max_length=1000)
class DAGRunClearBody(StrictBaseModel):
- """DAG Run serializer for clear endpoint body."""
+ """Dag Run serializer for clear endpoint body."""
dry_run: bool = True
only_failed: bool = False
only_new: bool = Field(
default=False,
- description="Only queue newly added tasks in the latest DAG version without clearing existing tasks.",
+ description="Only queue newly added tasks in the latest Dag version without clearing existing tasks.",
)
run_on_latest_version: bool = Field(
default=False,
@@ -67,14 +67,14 @@ class DAGRunClearBody(StrictBaseModel):
@model_validator(mode="before")
@classmethod
def validate_model(cls, data: Any) -> Any:
- """Validate clear DAG run form."""
+ """Validate clear Dag run form."""
if data.get("only_new") and data.get("only_failed"):
raise ValueError("only_new and only_failed are mutually exclusive")
return data
class DAGRunResponse(BaseModel):
- """DAG Run serializer for responses."""
+ """Dag Run serializer for responses."""
dag_run_id: str = Field(validation_alias="run_id")
dag_id: str
@@ -101,7 +101,7 @@ class DAGRunResponse(BaseModel):
class DAGRunCollectionResponse(BaseModel):
"""
- DAG Run collection response supporting both offset and cursor pagination.
+ Dag Run collection response supporting both offset and cursor pagination.
A single flat model is used instead of a discriminated union
(``Annotated[Offset | Cursor, Field(discriminator=...)]``) because
@@ -130,7 +130,7 @@ class DAGRunCollectionResponse(BaseModel):
class TriggerDAGRunPostBody(StrictBaseModel):
- """Trigger DAG Run Serializer for POST body."""
+ """Trigger Dag Run Serializer for POST body."""
dag_run_id: str | None = None
data_interval_start: AwareDatetime | None = None
@@ -180,7 +180,7 @@ class TriggerDAGRunPostBody(StrictBaseModel):
class DAGRunsBatchBody(StrictBaseModel):
- """List DAG Runs body for batch endpoint."""
+ """List Dag Runs body for batch endpoint."""
order_by: str | None = None
page_offset: NonNegativeInt = 0
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py
index c41d55f9aa2..fdc081a0ab2 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py
@@ -22,7 +22,7 @@ from airflow.api_fastapi.core_api.base import BaseModel
class DAGSourceResponse(BaseModel):
- """DAG Source serializer for responses."""
+ """Dag Source serializer for responses."""
content: str | None
dag_id: str
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py
index 921886b37c4..d07646f41a0 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py
@@ -31,7 +31,7 @@ class DagStatsStateResponse(BaseModel):
class DagStatsResponse(BaseModel):
- """DAG Stats serializer for responses."""
+ """Dag Stats serializer for responses."""
dag_id: str
dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
@@ -39,7 +39,7 @@ class DagStatsResponse(BaseModel):
class DagStatsCollectionResponse(BaseModel):
- """DAG Stats Collection serializer for responses."""
+ """Dag Stats Collection serializer for responses."""
dags: list[DagStatsResponse]
total_entries: int
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py
index 901787de1fb..1ca8ae61128 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py
@@ -23,7 +23,7 @@ from airflow.api_fastapi.core_api.base import BaseModel
class DagTagResponse(BaseModel):
- """DAG Tag serializer for responses."""
+ """Dag Tag serializer for responses."""
name: str
dag_id: str
@@ -31,7 +31,7 @@ class DagTagResponse(BaseModel):
class DAGTagCollectionResponse(BaseModel):
- """DAG Tags Collection serializer for responses."""
+ """Dag Tags Collection serializer for responses."""
tags: list[str]
total_entries: int
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py
index 0ec9f2fad8d..a9a7a585fd4 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py
@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):
class DAGVersionCollectionResponse(BaseModel):
- """DAG Version Collection serializer for responses."""
+ """Dag Version Collection serializer for responses."""
dag_versions: Iterable[DagVersionResponse]
total_entries: int
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py
index 255d8af14af..470a0b14fc6 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py
@@ -27,7 +27,7 @@ from airflow.models.dagwarning import DagWarningType
class DAGWarningResponse(BaseModel):
- """DAG Warning serializer for responses."""
+ """Dag Warning serializer for responses."""
dag_id: str
warning_type: DagWarningType
@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):
class DAGWarningCollectionResponse(BaseModel):
- """DAG warning collection serializer for responses."""
+ """Dag warning collection serializer for responses."""
dag_warnings: Iterable[DAGWarningResponse]
total_entries: int
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py
index 3574fdee3e3..27853cfecb4 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py
@@ -72,7 +72,7 @@ DAG_ALIAS_MAPPING: dict[str, str] = {
class DAGResponse(BaseModel):
- """DAG serializer for responses."""
+ """Dag serializer for responses."""
model_config = ConfigDict(
alias_generator=AliasGenerator(
@@ -117,7 +117,7 @@ class DAGResponse(BaseModel):
@field_validator("owners", mode="before")
@classmethod
def get_owners(cls, v: Any) -> list[str] | None:
- """Convert owners attribute to DAG representation."""
+ """Convert owners attribute to Dag representation."""
if not (v is None or isinstance(v, str)):
return v
@@ -139,7 +139,7 @@ class DAGResponse(BaseModel):
@computed_field # type: ignore[prop-decorator]
@property
def is_backfillable(self) -> bool:
- """Whether this DAG's schedule supports backfilling."""
+ """Whether this Dag's schedule supports backfilling."""
if not self.timetable_periodic:
return False
if self.allowed_run_types is not None and DagRunType.BACKFILL_JOB not in self.allowed_run_types:
@@ -168,14 +168,14 @@ DAGPatchBodyPartial = make_partial_model(DAGPatchBody)
class DAGCollectionResponse(BaseModel):
- """DAG Collection serializer for responses."""
+ """Dag Collection serializer for responses."""
dags: Iterable[DAGResponse]
total_entries: int
class DAGDetailsResponse(DAGResponse):
- """Specific serializer for DAG Details responses."""
+ """Specific serializer for Dag Details responses."""
model_config = ConfigDict(
from_attributes=True,
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 f8d52e6e5da..ddb37bf7c88 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
@@ -2258,7 +2258,7 @@ components:
is_backfillable:
type: boolean
title: Is Backfillable
- description: Whether this DAG's schedule supports backfilling.
+ description: Whether this Dag's schedule supports backfilling.
readOnly: true
file_token:
type: string
@@ -2347,7 +2347,7 @@ components:
- dag_id
- dag_display_name
title: DagTagResponse
- description: DAG Tag serializer for responses.
+ description: Dag Tag serializer for responses.
DagVersionResponse:
properties:
id:
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 d980fda4b5b..a56c9adf821 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
@@ -11576,7 +11576,7 @@ components:
- dags
- total_entries
title: DAGCollectionResponse
- description: DAG Collection serializer for responses.
+ description: Dag Collection serializer for responses.
DAGDetailsResponse:
properties:
dag_id:
@@ -11793,7 +11793,7 @@ components:
is_backfillable:
type: boolean
title: Is Backfillable
- description: Whether this DAG's schedule supports backfilling.
+ description: Whether this Dag's schedule supports backfilling.
readOnly: true
file_token:
type: string
@@ -11863,7 +11863,7 @@ components:
- concurrency
- latest_dag_version
title: DAGDetailsResponse
- description: Specific serializer for DAG Details responses.
+ description: Specific serializer for Dag Details responses.
DAGPatchBody:
properties:
is_paused:
@@ -12006,7 +12006,7 @@ components:
is_backfillable:
type: boolean
title: Is Backfillable
- description: Whether this DAG's schedule supports backfilling.
+ description: Whether this Dag's schedule supports backfilling.
readOnly: true
file_token:
type: string
@@ -12046,7 +12046,7 @@ components:
- is_backfillable
- file_token
title: DAGResponse
- description: DAG serializer for responses.
+ description: Dag serializer for responses.
DAGRunClearBody:
properties:
dry_run:
@@ -12060,7 +12060,7 @@ components:
only_new:
type: boolean
title: Only New
- description: Only queue newly added tasks in the latest DAG version without
+ description: Only queue newly added tasks in the latest Dag version without
clearing existing tasks.
default: false
run_on_latest_version:
@@ -12072,7 +12072,7 @@ components:
additionalProperties: false
type: object
title: DAGRunClearBody
- description: DAG Run serializer for clear endpoint body.
+ description: Dag Run serializer for clear endpoint body.
DAGRunCollectionResponse:
properties:
dag_runs:
@@ -12105,7 +12105,7 @@ components:
required:
- dag_runs
title: DAGRunCollectionResponse
- description: 'DAG Run collection response supporting both offset and cursor
+ description: 'Dag Run collection response supporting both offset and cursor
pagination.
@@ -12135,7 +12135,7 @@ components:
additionalProperties: false
type: object
title: DAGRunPatchBody
- description: DAG Run Serializer for PATCH requests.
+ description: Dag Run Serializer for PATCH requests.
DAGRunPatchStates:
type: string
enum:
@@ -12143,7 +12143,7 @@ components:
- success
- failed
title: DAGRunPatchStates
- description: Enum for DAG Run states when updating a DAG Run.
+ description: Enum for Dag Run states when updating a Dag Run.
DAGRunResponse:
properties:
dag_run_id:
@@ -12269,7 +12269,7 @@ components:
- dag_display_name
- partition_key
title: DAGRunResponse
- description: DAG Run serializer for responses.
+ description: Dag Run serializer for responses.
DAGRunsBatchBody:
properties:
order_by:
@@ -12427,7 +12427,7 @@ components:
additionalProperties: false
type: object
title: DAGRunsBatchBody
- description: List DAG Runs body for batch endpoint.
+ description: List Dag Runs body for batch endpoint.
DAGSourceResponse:
properties:
content:
@@ -12453,7 +12453,7 @@ components:
- version_number
- dag_display_name
title: DAGSourceResponse
- description: DAG Source serializer for responses.
+ description: Dag Source serializer for responses.
DAGTagCollectionResponse:
properties:
tags:
@@ -12469,7 +12469,7 @@ components:
- tags
- total_entries
title: DAGTagCollectionResponse
- description: DAG Tags Collection serializer for responses.
+ description: Dag Tags Collection serializer for responses.
DAGVersionCollectionResponse:
properties:
dag_versions:
@@ -12485,7 +12485,7 @@ components:
- dag_versions
- total_entries
title: DAGVersionCollectionResponse
- description: DAG Version Collection serializer for responses.
+ description: Dag Version Collection serializer for responses.
DAGWarningCollectionResponse:
properties:
dag_warnings:
@@ -12501,7 +12501,7 @@ components:
- dag_warnings
- total_entries
title: DAGWarningCollectionResponse
- description: DAG warning collection serializer for responses.
+ description: Dag warning collection serializer for responses.
DAGWarningResponse:
properties:
dag_id:
@@ -12527,7 +12527,7 @@ components:
- timestamp
- dag_display_name
title: DAGWarningResponse
- description: DAG Warning serializer for responses.
+ description: Dag Warning serializer for responses.
DagProcessorInfoResponse:
properties:
status:
@@ -12664,7 +12664,7 @@ components:
- created_at
- updated_at
title: DagScheduleAssetReference
- description: DAG schedule reference serializer for assets.
+ description: Dag schedule reference serializer for assets.
DagStatsCollectionResponse:
properties:
dags:
@@ -12680,7 +12680,7 @@ components:
- dags
- total_entries
title: DagStatsCollectionResponse
- description: DAG Stats Collection serializer for responses.
+ description: Dag Stats Collection serializer for responses.
DagStatsResponse:
properties:
dag_id:
@@ -12700,7 +12700,7 @@ components:
- dag_display_name
- stats
title: DagStatsResponse
- description: DAG Stats serializer for responses.
+ description: Dag Stats serializer for responses.
DagStatsStateResponse:
properties:
state:
@@ -12731,7 +12731,7 @@ components:
- dag_id
- dag_display_name
title: DagTagResponse
- description: DAG Tag serializer for responses.
+ description: Dag Tag serializer for responses.
DagVersionResponse:
properties:
id:
@@ -14929,7 +14929,7 @@ components:
required:
- logical_date
title: TriggerDAGRunPostBody
- description: Trigger DAG Run Serializer for POST body.
+ description: Trigger Dag Run Serializer for POST body.
TriggerResponse:
properties:
id:
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/schemas.gen.ts b/airflow-core/src/airflow/ui/openapi-gen/requests/schemas.gen.ts
index 8b099769c87..bc4c7179c2d 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/schemas.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/schemas.gen.ts
@@ -1807,7 +1807,7 @@ export const $DAGCollectionResponse = {
type: 'object',
required: ['dags', 'total_entries'],
title: 'DAGCollectionResponse',
- description: 'DAG Collection serializer for responses.'
+ description: 'Dag Collection serializer for responses.'
} as const;
export const $DAGDetailsResponse = {
@@ -2210,7 +2210,7 @@ export const $DAGDetailsResponse = {
is_backfillable: {
type: 'boolean',
title: 'Is Backfillable',
- description: "Whether this DAG's schedule supports backfilling.",
+ description: "Whether this Dag's schedule supports backfilling.",
readOnly: true
},
file_token: {
@@ -2244,7 +2244,7 @@ Deprecated: Use max_active_tasks instead.`,
type: 'object',
required: ['dag_id', 'dag_display_name', 'is_paused', 'is_stale', 'last_parsed_time', 'last_parse_duration', 'last_expired', 'bundle_name', 'bundle_version', 'relative_fileloc', 'fileloc', 'description', 'timetable_summary', 'timetable_description', 'timetable_partitioned', 'timetable_periodic', 'tags', 'max_active_tasks', 'max_active_runs', 'max_consecutive_failed_dag_runs', 'has_task_concurrency_limits', 'has_import_errors', 'next_dagrun_logical_date', 'next_dagrun_data_interval_st [...]
title: 'DAGDetailsResponse',
- description: 'Specific serializer for DAG Details responses.'
+ description: 'Specific serializer for Dag Details responses.'
} as const;
export const $DAGPatchBody = {
@@ -2498,7 +2498,7 @@ export const $DAGResponse = {
is_backfillable: {
type: 'boolean',
title: 'Is Backfillable',
- description: "Whether this DAG's schedule supports backfilling.",
+ description: "Whether this Dag's schedule supports backfilling.",
readOnly: true
},
file_token: {
@@ -2511,7 +2511,7 @@ export const $DAGResponse = {
type: 'object',
required: ['dag_id', 'dag_display_name', 'is_paused', 'is_stale', 'last_parsed_time', 'last_parse_duration', 'last_expired', 'bundle_name', 'bundle_version', 'relative_fileloc', 'fileloc', 'description', 'timetable_summary', 'timetable_description', 'timetable_partitioned', 'timetable_periodic', 'tags', 'max_active_tasks', 'max_active_runs', 'max_consecutive_failed_dag_runs', 'has_task_concurrency_limits', 'has_import_errors', 'next_dagrun_logical_date', 'next_dagrun_data_interval_st [...]
title: 'DAGResponse',
- description: 'DAG serializer for responses.'
+ description: 'Dag serializer for responses.'
} as const;
export const $DAGRunClearBody = {
@@ -2529,7 +2529,7 @@ export const $DAGRunClearBody = {
only_new: {
type: 'boolean',
title: 'Only New',
- description: 'Only queue newly added tasks in the latest DAG version without clearing existing tasks.',
+ description: 'Only queue newly added tasks in the latest Dag version without clearing existing tasks.',
default: false
},
run_on_latest_version: {
@@ -2542,7 +2542,7 @@ export const $DAGRunClearBody = {
additionalProperties: false,
type: 'object',
title: 'DAGRunClearBody',
- description: 'DAG Run serializer for clear endpoint body.'
+ description: 'Dag Run serializer for clear endpoint body.'
} as const;
export const $DAGRunCollectionResponse = {
@@ -2594,7 +2594,7 @@ export const $DAGRunCollectionResponse = {
type: 'object',
required: ['dag_runs'],
title: 'DAGRunCollectionResponse',
- description: `DAG Run collection response supporting both offset and cursor pagination.
+ description: `Dag Run collection response supporting both offset and cursor pagination.
A single flat model is used instead of a discriminated union
(\`\`Annotated[Offset | Cursor, Field(discriminator=...)]\`\`) because
@@ -2632,14 +2632,14 @@ export const $DAGRunPatchBody = {
additionalProperties: false,
type: 'object',
title: 'DAGRunPatchBody',
- description: 'DAG Run Serializer for PATCH requests.'
+ description: 'Dag Run Serializer for PATCH requests.'
} as const;
export const $DAGRunPatchStates = {
type: 'string',
enum: ['queued', 'success', 'failed'],
title: 'DAGRunPatchStates',
- description: 'Enum for DAG Run states when updating a DAG Run.'
+ description: 'Enum for Dag Run states when updating a Dag Run.'
} as const;
export const $DAGRunResponse = {
@@ -2839,7 +2839,7 @@ export const $DAGRunResponse = {
type: 'object',
required: ['dag_run_id', 'dag_id', 'logical_date', 'queued_at', 'start_date', 'end_date', 'duration', 'data_interval_start', 'data_interval_end', 'run_after', 'last_scheduling_decision', 'run_type', 'state', 'triggered_by', 'triggering_user_name', 'conf', 'note', 'dag_versions', 'bundle_version', 'dag_display_name', 'partition_key'],
title: 'DAGRunResponse',
- description: 'DAG Run serializer for responses.'
+ description: 'Dag Run serializer for responses.'
} as const;
export const $DAGRunsBatchBody = {
@@ -3153,7 +3153,7 @@ export const $DAGRunsBatchBody = {
additionalProperties: false,
type: 'object',
title: 'DAGRunsBatchBody',
- description: 'List DAG Runs body for batch endpoint.'
+ description: 'List Dag Runs body for batch endpoint.'
} as const;
export const $DAGSourceResponse = {
@@ -3192,7 +3192,7 @@ export const $DAGSourceResponse = {
type: 'object',
required: ['content', 'dag_id', 'version_number', 'dag_display_name'],
title: 'DAGSourceResponse',
- description: 'DAG Source serializer for responses.'
+ description: 'Dag Source serializer for responses.'
} as const;
export const $DAGTagCollectionResponse = {
@@ -3212,7 +3212,7 @@ export const $DAGTagCollectionResponse = {
type: 'object',
required: ['tags', 'total_entries'],
title: 'DAGTagCollectionResponse',
- description: 'DAG Tags Collection serializer for responses.'
+ description: 'Dag Tags Collection serializer for responses.'
} as const;
export const $DAGVersionCollectionResponse = {
@@ -3232,7 +3232,7 @@ export const $DAGVersionCollectionResponse = {
type: 'object',
required: ['dag_versions', 'total_entries'],
title: 'DAGVersionCollectionResponse',
- description: 'DAG Version Collection serializer for responses.'
+ description: 'Dag Version Collection serializer for responses.'
} as const;
export const $DAGWarningCollectionResponse = {
@@ -3252,7 +3252,7 @@ export const $DAGWarningCollectionResponse = {
type: 'object',
required: ['dag_warnings', 'total_entries'],
title: 'DAGWarningCollectionResponse',
- description: 'DAG warning collection serializer for responses.'
+ description: 'Dag warning collection serializer for responses.'
} as const;
export const $DAGWarningResponse = {
@@ -3281,7 +3281,7 @@ export const $DAGWarningResponse = {
type: 'object',
required: ['dag_id', 'warning_type', 'message', 'timestamp', 'dag_display_name'],
title: 'DAGWarningResponse',
- description: 'DAG Warning serializer for responses.'
+ description: 'Dag Warning serializer for responses.'
} as const;
export const $DagProcessorInfoResponse = {
@@ -3447,7 +3447,7 @@ export const $DagScheduleAssetReference = {
type: 'object',
required: ['dag_id', 'created_at', 'updated_at'],
title: 'DagScheduleAssetReference',
- description: 'DAG schedule reference serializer for assets.'
+ description: 'Dag schedule reference serializer for assets.'
} as const;
export const $DagStatsCollectionResponse = {
@@ -3467,7 +3467,7 @@ export const $DagStatsCollectionResponse = {
type: 'object',
required: ['dags', 'total_entries'],
title: 'DagStatsCollectionResponse',
- description: 'DAG Stats Collection serializer for responses.'
+ description: 'Dag Stats Collection serializer for responses.'
} as const;
export const $DagStatsResponse = {
@@ -3491,7 +3491,7 @@ export const $DagStatsResponse = {
type: 'object',
required: ['dag_id', 'dag_display_name', 'stats'],
title: 'DagStatsResponse',
- description: 'DAG Stats serializer for responses.'
+ description: 'Dag Stats serializer for responses.'
} as const;
export const $DagStatsStateResponse = {
@@ -3528,7 +3528,7 @@ export const $DagTagResponse = {
type: 'object',
required: ['name', 'dag_id', 'dag_display_name'],
title: 'DagTagResponse',
- description: 'DAG Tag serializer for responses.'
+ description: 'Dag Tag serializer for responses.'
} as const;
export const $DagVersionResponse = {
@@ -6864,7 +6864,7 @@ export const $TriggerDAGRunPostBody = {
type: 'object',
required: ['logical_date'],
title: 'TriggerDAGRunPostBody',
- description: 'Trigger DAG Run Serializer for POST body.'
+ description: 'Trigger Dag Run Serializer for POST body.'
} as const;
export const $TriggerResponse = {
@@ -8081,7 +8081,7 @@ export const $DAGWithLatestDagRunsResponse = {
is_backfillable: {
type: 'boolean',
title: 'Is Backfillable',
- description: "Whether this DAG's schedule supports backfilling.",
+ description: "Whether this Dag's schedule supports backfilling.",
readOnly: true
},
file_token: {
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 bb0fa50ce2a..5b216da03a5 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
@@ -524,7 +524,7 @@ export type CreateAssetEventsBody = {
};
/**
- * DAG Collection serializer for responses.
+ * Dag Collection serializer for responses.
*/
export type DAGCollectionResponse = {
dags: Array<DAGResponse>;
@@ -532,7 +532,7 @@ export type DAGCollectionResponse = {
};
/**
- * Specific serializer for DAG Details responses.
+ * Specific serializer for Dag Details responses.
*/
export type DAGDetailsResponse = {
dag_id: string;
@@ -588,7 +588,7 @@ export type DAGDetailsResponse = {
is_favorite?: boolean;
active_runs_count?: number;
/**
- * Whether this DAG's schedule supports backfilling.
+ * Whether this Dag's schedule supports backfilling.
*/
readonly is_backfillable: boolean;
/**
@@ -616,7 +616,7 @@ export type DAGPatchBody = {
};
/**
- * DAG serializer for responses.
+ * Dag serializer for responses.
*/
export type DAGResponse = {
dag_id: string;
@@ -648,7 +648,7 @@ export type DAGResponse = {
allowed_run_types: Array<DagRunType> | null;
owners: Array<(string)>;
/**
- * Whether this DAG's schedule supports backfilling.
+ * Whether this Dag's schedule supports backfilling.
*/
readonly is_backfillable: boolean;
/**
@@ -658,13 +658,13 @@ export type DAGResponse = {
};
/**
- * DAG Run serializer for clear endpoint body.
+ * Dag Run serializer for clear endpoint body.
*/
export type DAGRunClearBody = {
dry_run?: boolean;
only_failed?: boolean;
/**
- * Only queue newly added tasks in the latest DAG version without clearing existing tasks.
+ * Only queue newly added tasks in the latest Dag version without clearing existing tasks.
*/
only_new?: boolean;
/**
@@ -674,7 +674,7 @@ export type DAGRunClearBody = {
};
/**
- * DAG Run collection response supporting both offset and cursor pagination.
+ * Dag Run collection response supporting both offset and cursor pagination.
*
* A single flat model is used instead of a discriminated union
* (``Annotated[Offset | Cursor, Field(discriminator=...)]``) because
@@ -700,7 +700,7 @@ export type DAGRunCollectionResponse = {
};
/**
- * DAG Run Serializer for PATCH requests.
+ * Dag Run Serializer for PATCH requests.
*/
export type DAGRunPatchBody = {
state?: DAGRunPatchStates | null;
@@ -708,12 +708,12 @@ export type DAGRunPatchBody = {
};
/**
- * Enum for DAG Run states when updating a DAG Run.
+ * Enum for Dag Run states when updating a Dag Run.
*/
export type DAGRunPatchStates = 'queued' | 'success' | 'failed';
/**
- * DAG Run serializer for responses.
+ * Dag Run serializer for responses.
*/
export type DAGRunResponse = {
dag_run_id: string;
@@ -742,7 +742,7 @@ export type DAGRunResponse = {
};
/**
- * List DAG Runs body for batch endpoint.
+ * List Dag Runs body for batch endpoint.
*/
export type DAGRunsBatchBody = {
order_by?: string | null;
@@ -774,7 +774,7 @@ export type DAGRunsBatchBody = {
};
/**
- * DAG Source serializer for responses.
+ * Dag Source serializer for responses.
*/
export type DAGSourceResponse = {
content: string | null;
@@ -784,7 +784,7 @@ export type DAGSourceResponse = {
};
/**
- * DAG Tags Collection serializer for responses.
+ * Dag Tags Collection serializer for responses.
*/
export type DAGTagCollectionResponse = {
tags: Array<(string)>;
@@ -792,7 +792,7 @@ export type DAGTagCollectionResponse = {
};
/**
- * DAG Version Collection serializer for responses.
+ * Dag Version Collection serializer for responses.
*/
export type DAGVersionCollectionResponse = {
dag_versions: Array<DagVersionResponse>;
@@ -800,7 +800,7 @@ export type DAGVersionCollectionResponse = {
};
/**
- * DAG warning collection serializer for responses.
+ * Dag warning collection serializer for responses.
*/
export type DAGWarningCollectionResponse = {
dag_warnings: Array<DAGWarningResponse>;
@@ -808,7 +808,7 @@ export type DAGWarningCollectionResponse = {
};
/**
- * DAG Warning serializer for responses.
+ * Dag Warning serializer for responses.
*/
export type DAGWarningResponse = {
dag_id: string;
@@ -861,7 +861,7 @@ export type DagRunTriggeredByType = 'cli' | 'operator' | 'rest_api' | 'ui' | 'te
export type DagRunType = 'backfill' | 'scheduled' | 'manual' | 'operator_triggered' | 'asset_triggered' | 'asset_materialization';
/**
- * DAG schedule reference serializer for assets.
+ * Dag schedule reference serializer for assets.
*/
export type DagScheduleAssetReference = {
dag_id: string;
@@ -870,7 +870,7 @@ export type DagScheduleAssetReference = {
};
/**
- * DAG Stats Collection serializer for responses.
+ * Dag Stats Collection serializer for responses.
*/
export type DagStatsCollectionResponse = {
dags: Array<DagStatsResponse>;
@@ -878,7 +878,7 @@ export type DagStatsCollectionResponse = {
};
/**
- * DAG Stats serializer for responses.
+ * Dag Stats serializer for responses.
*/
export type DagStatsResponse = {
dag_id: string;
@@ -895,7 +895,7 @@ export type DagStatsStateResponse = {
};
/**
- * DAG Tag serializer for responses.
+ * Dag Tag serializer for responses.
*/
export type DagTagResponse = {
name: string;
@@ -1642,7 +1642,7 @@ export type TimeDelta = {
};
/**
- * Trigger DAG Run Serializer for POST body.
+ * Trigger Dag Run Serializer for POST body.
*/
export type TriggerDAGRunPostBody = {
dag_run_id?: string | null;
@@ -1989,7 +1989,7 @@ export type DAGWithLatestDagRunsResponse = {
pending_actions: Array<HITLDetail>;
is_favorite: boolean;
/**
- * Whether this DAG's schedule supports backfilling.
+ * Whether this Dag's schedule supports backfilling.
*/
readonly is_backfillable: boolean;
/**
diff --git a/airflow-ctl/docs/howto/index.rst b/airflow-ctl/docs/howto/index.rst
index 155dab5fc04..59f806d4f44 100644
--- a/airflow-ctl/docs/howto/index.rst
+++ b/airflow-ctl/docs/howto/index.rst
@@ -39,7 +39,7 @@ Datetime Usage
''''''''''''''
For datetime parameters, date should be timezone aware and in ISO format.
For example: ``2025-10-10T10:00:00+00:00``
-Let's take example of triggering a DAG run with a logical date, run after and a note.
+Let's take example of triggering a Dag run with a logical date, run after and a note.
.. code-block:: bash
diff --git a/airflow-ctl/docs/images/command_hashes.txt b/airflow-ctl/docs/images/command_hashes.txt
index c824ba2f9ab..8e590f3b820 100644
--- a/airflow-ctl/docs/images/command_hashes.txt
+++ b/airflow-ctl/docs/images/command_hashes.txt
@@ -1,11 +1,11 @@
main:27a22c00dcf32e7a1a4f06672dc8e3c8
-assets:6e2d3f0f73df1bd794a6b7d8fefffdc3
+assets:70619a2d92bda80930cde2aefcd8e1cd
auth:d79e9c7d00c432bdbcbc2a86e2e32053
-backfill:41e008e4bc78d44e69bd9769098ba3b0
+backfill:74c8737b0a62a86ed3605fa9e6165874
config:a3d936cb15fe3b547bf6c82cf93d923f
connections:942f9f88cb908c28bf5c19159fc5065b
-dags:d9d0b3460097db0b9fbf8ae42bf500c3
-dagrun:0e46473ad2f3dfa1ee9ee27678dde57e
+dags:e2a18f90b1bd150be981cef6fef91858
+dagrun:c32e0011aa9a845456c778786717208e
jobs:a5b644c5da8889443bb40ee10b599270
pools:19efe105b9515ab1926ebcaf0e028d71
providers:34502fe09dc0b8b0a13e7e46efdffda6
diff --git a/airflow-ctl/docs/images/output_assets.svg b/airflow-ctl/docs/images/output_assets.svg
index 07e78ea7c1e..b76118dc52a 100644
--- a/airflow-ctl/docs/images/output_assets.svg
+++ b/airflow-ctl/docs/images/output_assets.svg
@@ -19,108 +19,108 @@
font-weight: 700;
}
- .terminal-4223370654-matrix {
+ .terminal-3582101150-matrix {
font-family: Fira Code, monospace;
font-size: 20px;
line-height: 24.4px;
font-variant-east-asian: full-width;
}
- .terminal-4223370654-title {
+ .terminal-3582101150-title {
font-size: 18px;
font-weight: bold;
font-family: arial;
}
- .terminal-4223370654-r1 { fill: #ff8700 }
-.terminal-4223370654-r2 { fill: #c5c8c6 }
-.terminal-4223370654-r3 { fill: #808080 }
-.terminal-4223370654-r4 { fill: #68a0b3 }
+ .terminal-3582101150-r1 { fill: #ff8700 }
+.terminal-3582101150-r2 { fill: #c5c8c6 }
+.terminal-3582101150-r3 { fill: #808080 }
+.terminal-3582101150-r4 { fill: #68a0b3 }
</style>
<defs>
- <clipPath id="terminal-4223370654-clip-terminal">
+ <clipPath id="terminal-3582101150-clip-terminal">
<rect x="0" y="0" width="914.0" height="682.1999999999999" />
</clipPath>
- <clipPath id="terminal-4223370654-line-0">
+ <clipPath id="terminal-3582101150-line-0">
<rect x="0" y="1.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-1">
+<clipPath id="terminal-3582101150-line-1">
<rect x="0" y="25.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-2">
+<clipPath id="terminal-3582101150-line-2">
<rect x="0" y="50.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-3">
+<clipPath id="terminal-3582101150-line-3">
<rect x="0" y="74.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-4">
+<clipPath id="terminal-3582101150-line-4">
<rect x="0" y="99.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-5">
+<clipPath id="terminal-3582101150-line-5">
<rect x="0" y="123.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-6">
+<clipPath id="terminal-3582101150-line-6">
<rect x="0" y="147.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-7">
+<clipPath id="terminal-3582101150-line-7">
<rect x="0" y="172.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-8">
+<clipPath id="terminal-3582101150-line-8">
<rect x="0" y="196.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-9">
+<clipPath id="terminal-3582101150-line-9">
<rect x="0" y="221.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-10">
+<clipPath id="terminal-3582101150-line-10">
<rect x="0" y="245.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-11">
+<clipPath id="terminal-3582101150-line-11">
<rect x="0" y="269.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-12">
+<clipPath id="terminal-3582101150-line-12">
<rect x="0" y="294.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-13">
+<clipPath id="terminal-3582101150-line-13">
<rect x="0" y="318.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-14">
+<clipPath id="terminal-3582101150-line-14">
<rect x="0" y="343.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-15">
+<clipPath id="terminal-3582101150-line-15">
<rect x="0" y="367.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-16">
+<clipPath id="terminal-3582101150-line-16">
<rect x="0" y="391.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-17">
+<clipPath id="terminal-3582101150-line-17">
<rect x="0" y="416.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-18">
+<clipPath id="terminal-3582101150-line-18">
<rect x="0" y="440.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-19">
+<clipPath id="terminal-3582101150-line-19">
<rect x="0" y="465.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-20">
+<clipPath id="terminal-3582101150-line-20">
<rect x="0" y="489.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-21">
+<clipPath id="terminal-3582101150-line-21">
<rect x="0" y="513.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-22">
+<clipPath id="terminal-3582101150-line-22">
<rect x="0" y="538.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-23">
+<clipPath id="terminal-3582101150-line-23">
<rect x="0" y="562.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-24">
+<clipPath id="terminal-3582101150-line-24">
<rect x="0" y="587.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-25">
+<clipPath id="terminal-3582101150-line-25">
<rect x="0" y="611.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-4223370654-line-26">
+<clipPath id="terminal-3582101150-line-26">
<rect x="0" y="635.9" width="915" height="24.65"/>
</clipPath>
</defs>
@@ -132,37 +132,37 @@
<circle cx="44" cy="0" r="7" fill="#28c840"/>
</g>
- <g transform="translate(9, 41)" clip-path="url(#terminal-4223370654-clip-terminal)">
+ <g transform="translate(9, 41)" clip-path="url(#terminal-3582101150-clip-terminal)">
- <g class="terminal-4223370654-matrix">
- <text class="terminal-4223370654-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-4223370654-line-0)">Usage:</text><text class="terminal-4223370654-r3" x="85.4" y="20" textLength="207.4" clip-path="url(#terminal-4223370654-line-0)">airflowctl assets</text><text class="terminal-4223370654-r2" x="292.8" y="20" textLength="24.4" clip-path="url(#terminal-4223370654-line-0)"> [</text><text class="terminal-4223370654-r4" x="317.2" y="20" textLength="24.4" clip-path="ur [...]
-</text><text class="terminal-4223370654-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-4223370654-line-1)">
-</text><text class="terminal-4223370654-r2" x="0" y="68.8" textLength="305" clip-path="url(#terminal-4223370654-line-2)">Perform Assets operations</text><text class="terminal-4223370654-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-4223370654-line-2)">
-</text><text class="terminal-4223370654-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-4223370654-line-3)">
-</text><text class="terminal-4223370654-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-4223370654-line-4)">Positional Arguments:</text><text class="terminal-4223370654-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-4223370654-line-4)">
-</text><text class="terminal-4223370654-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-4223370654-line-5)">COMMAND</text><text class="terminal-4223370654-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-4223370654-line-5)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="166.4" textLength="146.4" clip-path="url(#terminal-4223370654-line-6)">create-event</text><text class="terminal-4223370654-r2" x="292.8" y="166.4" textLength="402.6" clip-path="url(#terminal-4223370654-line-6)">Create an event for a given asset</text><text class="terminal-4223370654-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-4223370654-line-6)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="190.8" textLength="292.8" clip-path="url(#terminal-4223370654-line-7)">delete-dag-queued-events</text><text class="terminal-4223370654-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-4223370654-line-7)">
-</text><text class="terminal-4223370654-r2" x="292.8" y="215.2" textLength="561.2" clip-path="url(#terminal-4223370654-line-8)">Delete all queued asset events for a given DAG</text><text class="terminal-4223370654-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-4223370654-line-8)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="239.6" textLength="231.8" clip-path="url(#terminal-4223370654-line-9)">delete-queued-event</text><text class="terminal-4223370654-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-4223370654-line-9)">
-</text><text class="terminal-4223370654-r2" x="292.8" y="264" textLength="597.8" clip-path="url(#terminal-4223370654-line-10)">Delete a specific queued asset event for a given </text><text class="terminal-4223370654-r2" x="915" y="264" textLength="12.2" clip-path="url(#terminal-4223370654-line-10)">
-</text><text class="terminal-4223370654-r2" x="0" y="288.4" textLength="158.6" clip-path="url(#terminal-4223370654-line-11)">DAG and asset</text><text class="terminal-4223370654-r2" x="915" y="288.4" textLength="12.2" clip-path="url(#terminal-4223370654-line-11)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="312.8" textLength="244" clip-path="url(#terminal-4223370654-line-12)">delete-queued-events</text><text class="terminal-4223370654-r2" x="915" y="312.8" textLength="12.2" clip-path="url(#terminal-4223370654-line-12)">
-</text><text class="terminal-4223370654-r2" x="292.8" y="337.2" textLength="512.4" clip-path="url(#terminal-4223370654-line-13)">Delete all queued events for a given asset</text><text class="terminal-4223370654-r2" x="915" y="337.2" textLength="12.2" clip-path="url(#terminal-4223370654-line-13)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="361.6" textLength="36.6" clip-path="url(#terminal-4223370654-line-14)">get</text><text class="terminal-4223370654-r2" x="292.8" y="361.6" textLength="329.4" clip-path="url(#terminal-4223370654-line-14)">Retrieve an asset by its ID</text><text class="terminal-4223370654-r2" x="915" y="361.6" textLength="12.2" clip-path="url(#terminal-4223370654-line-14)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="386" textLength="146.4" clip-path="url(#terminal-4223370654-line-15)">get-by-alias</text><text class="terminal-4223370654-r2" x="292.8" y="386" textLength="366" clip-path="url(#terminal-4223370654-line-15)">Retrieve an asset by its alias</text><text class="terminal-4223370654-r2" x="915" y="386" textLength="12.2" clip-path="url(#terminal-4223370654-line-15)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="410.4" textLength="244" clip-path="url(#terminal-4223370654-line-16)">get-dag-queued-event</text><text class="terminal-4223370654-r2" x="915" y="410.4" textLength="12.2" clip-path="url(#terminal-4223370654-line-16)">
-</text><text class="terminal-4223370654-r2" x="292.8" y="434.8" textLength="622.2" clip-path="url(#terminal-4223370654-line-17)">Retrieve a specific queued asset event for a given </text><text class="terminal-4223370654-r2" x="915" y="434.8" textLength="12.2" clip-path="url(#terminal-4223370654-line-17)">
-</text><text class="terminal-4223370654-r2" x="0" y="459.2" textLength="158.6" clip-path="url(#terminal-4223370654-line-18)">DAG and asset</text><text class="terminal-4223370654-r2" x="915" y="459.2" textLength="12.2" clip-path="url(#terminal-4223370654-line-18)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="483.6" textLength="256.2" clip-path="url(#terminal-4223370654-line-19)">get-dag-queued-events</text><text class="terminal-4223370654-r2" x="915" y="483.6" textLength="12.2" clip-path="url(#terminal-4223370654-line-19)">
-</text><text class="terminal-4223370654-r2" x="292.8" y="508" textLength="488" clip-path="url(#terminal-4223370654-line-20)">List queued asset events for a given DAG</text><text class="terminal-4223370654-r2" x="915" y="508" textLength="12.2" clip-path="url(#terminal-4223370654-line-20)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="532.4" textLength="207.4" clip-path="url(#terminal-4223370654-line-21)">get-queued-events</text><text class="terminal-4223370654-r2" x="292.8" y="532.4" textLength="439.2" clip-path="url(#terminal-4223370654-line-21)">List queued events for a given asset</text><text class="terminal-4223370654-r2" x="915" y="532.4" textLength="12.2" clip-path="url(#terminal-4223370654-line-21)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="556.8" textLength="48.8" clip-path="url(#terminal-4223370654-line-22)">list</text><text class="terminal-4223370654-r2" x="292.8" y="556.8" textLength="183" clip-path="url(#terminal-4223370654-line-22)">List all assets</text><text class="terminal-4223370654-r2" x="915" y="556.8" textLength="12.2" clip-path="url(#terminal-4223370654-line-22)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="581.2" textLength="158.6" clip-path="url(#terminal-4223370654-line-23)">list-by-alias</text><text class="terminal-4223370654-r2" x="292.8" y="581.2" textLength="268.4" clip-path="url(#terminal-4223370654-line-23)">List all asset aliases</text><text class="terminal-4223370654-r2" x="915" y="581.2" textLength="12.2" clip-path="url(#terminal-4223370654-line-23)">
-</text><text class="terminal-4223370654-r4" x="48.8" y="605.6" textLength="134.2" clip-path="url(#terminal-4223370654-line-24)">materialize</text><text class="terminal-4223370654-r2" x="292.8" y="605.6" textLength="549" clip-path="url(#terminal-4223370654-line-24)">Trigger materialization of an asset by its ID</text><text class="terminal-4223370654-r2" x="915" y="605.6" textLength="12.2" clip-path="url(#terminal-4223370654-line-24)">
-</text><text class="terminal-4223370654-r2" x="915" y="630" textLength="12.2" clip-path="url(#terminal-4223370654-line-25)">
-</text><text class="terminal-4223370654-r1" x="0" y="654.4" textLength="97.6" clip-path="url(#terminal-4223370654-line-26)">Options:</text><text class="terminal-4223370654-r2" x="915" y="654.4" textLength="12.2" clip-path="url(#terminal-4223370654-line-26)">
-</text><text class="terminal-4223370654-r4" x="24.4" y="678.8" textLength="24.4" clip-path="url(#terminal-4223370654-line-27)">-h</text><text class="terminal-4223370654-r2" x="48.8" y="678.8" textLength="24.4" clip-path="url(#terminal-4223370654-line-27)">, </text><text class="terminal-4223370654-r4" x="73.2" y="678.8" textLength="73.2" clip-path="url(#terminal-4223370654-line-27)">--help</text><text class="terminal-4223370654-r2" x="292.8" y="678.8" textLength="378.2" clip-path="ur [...]
+ <g class="terminal-3582101150-matrix">
+ <text class="terminal-3582101150-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-3582101150-line-0)">Usage:</text><text class="terminal-3582101150-r3" x="85.4" y="20" textLength="207.4" clip-path="url(#terminal-3582101150-line-0)">airflowctl assets</text><text class="terminal-3582101150-r2" x="292.8" y="20" textLength="24.4" clip-path="url(#terminal-3582101150-line-0)"> [</text><text class="terminal-3582101150-r4" x="317.2" y="20" textLength="24.4" clip-path="ur [...]
+</text><text class="terminal-3582101150-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-3582101150-line-1)">
+</text><text class="terminal-3582101150-r2" x="0" y="68.8" textLength="305" clip-path="url(#terminal-3582101150-line-2)">Perform Assets operations</text><text class="terminal-3582101150-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-3582101150-line-2)">
+</text><text class="terminal-3582101150-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-3582101150-line-3)">
+</text><text class="terminal-3582101150-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-3582101150-line-4)">Positional Arguments:</text><text class="terminal-3582101150-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-3582101150-line-4)">
+</text><text class="terminal-3582101150-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-3582101150-line-5)">COMMAND</text><text class="terminal-3582101150-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-3582101150-line-5)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="166.4" textLength="146.4" clip-path="url(#terminal-3582101150-line-6)">create-event</text><text class="terminal-3582101150-r2" x="292.8" y="166.4" textLength="402.6" clip-path="url(#terminal-3582101150-line-6)">Create an event for a given asset</text><text class="terminal-3582101150-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-3582101150-line-6)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="190.8" textLength="292.8" clip-path="url(#terminal-3582101150-line-7)">delete-dag-queued-events</text><text class="terminal-3582101150-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-3582101150-line-7)">
+</text><text class="terminal-3582101150-r2" x="292.8" y="215.2" textLength="561.2" clip-path="url(#terminal-3582101150-line-8)">Delete all queued asset events for a given Dag</text><text class="terminal-3582101150-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-3582101150-line-8)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="239.6" textLength="231.8" clip-path="url(#terminal-3582101150-line-9)">delete-queued-event</text><text class="terminal-3582101150-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-3582101150-line-9)">
+</text><text class="terminal-3582101150-r2" x="292.8" y="264" textLength="597.8" clip-path="url(#terminal-3582101150-line-10)">Delete a specific queued asset event for a given </text><text class="terminal-3582101150-r2" x="915" y="264" textLength="12.2" clip-path="url(#terminal-3582101150-line-10)">
+</text><text class="terminal-3582101150-r2" x="0" y="288.4" textLength="158.6" clip-path="url(#terminal-3582101150-line-11)">Dag and asset</text><text class="terminal-3582101150-r2" x="915" y="288.4" textLength="12.2" clip-path="url(#terminal-3582101150-line-11)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="312.8" textLength="244" clip-path="url(#terminal-3582101150-line-12)">delete-queued-events</text><text class="terminal-3582101150-r2" x="915" y="312.8" textLength="12.2" clip-path="url(#terminal-3582101150-line-12)">
+</text><text class="terminal-3582101150-r2" x="292.8" y="337.2" textLength="512.4" clip-path="url(#terminal-3582101150-line-13)">Delete all queued events for a given asset</text><text class="terminal-3582101150-r2" x="915" y="337.2" textLength="12.2" clip-path="url(#terminal-3582101150-line-13)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="361.6" textLength="36.6" clip-path="url(#terminal-3582101150-line-14)">get</text><text class="terminal-3582101150-r2" x="292.8" y="361.6" textLength="329.4" clip-path="url(#terminal-3582101150-line-14)">Retrieve an asset by its ID</text><text class="terminal-3582101150-r2" x="915" y="361.6" textLength="12.2" clip-path="url(#terminal-3582101150-line-14)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="386" textLength="146.4" clip-path="url(#terminal-3582101150-line-15)">get-by-alias</text><text class="terminal-3582101150-r2" x="292.8" y="386" textLength="366" clip-path="url(#terminal-3582101150-line-15)">Retrieve an asset by its alias</text><text class="terminal-3582101150-r2" x="915" y="386" textLength="12.2" clip-path="url(#terminal-3582101150-line-15)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="410.4" textLength="244" clip-path="url(#terminal-3582101150-line-16)">get-dag-queued-event</text><text class="terminal-3582101150-r2" x="915" y="410.4" textLength="12.2" clip-path="url(#terminal-3582101150-line-16)">
+</text><text class="terminal-3582101150-r2" x="292.8" y="434.8" textLength="622.2" clip-path="url(#terminal-3582101150-line-17)">Retrieve a specific queued asset event for a given </text><text class="terminal-3582101150-r2" x="915" y="434.8" textLength="12.2" clip-path="url(#terminal-3582101150-line-17)">
+</text><text class="terminal-3582101150-r2" x="0" y="459.2" textLength="158.6" clip-path="url(#terminal-3582101150-line-18)">Dag and asset</text><text class="terminal-3582101150-r2" x="915" y="459.2" textLength="12.2" clip-path="url(#terminal-3582101150-line-18)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="483.6" textLength="256.2" clip-path="url(#terminal-3582101150-line-19)">get-dag-queued-events</text><text class="terminal-3582101150-r2" x="915" y="483.6" textLength="12.2" clip-path="url(#terminal-3582101150-line-19)">
+</text><text class="terminal-3582101150-r2" x="292.8" y="508" textLength="488" clip-path="url(#terminal-3582101150-line-20)">List queued asset events for a given Dag</text><text class="terminal-3582101150-r2" x="915" y="508" textLength="12.2" clip-path="url(#terminal-3582101150-line-20)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="532.4" textLength="207.4" clip-path="url(#terminal-3582101150-line-21)">get-queued-events</text><text class="terminal-3582101150-r2" x="292.8" y="532.4" textLength="439.2" clip-path="url(#terminal-3582101150-line-21)">List queued events for a given asset</text><text class="terminal-3582101150-r2" x="915" y="532.4" textLength="12.2" clip-path="url(#terminal-3582101150-line-21)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="556.8" textLength="48.8" clip-path="url(#terminal-3582101150-line-22)">list</text><text class="terminal-3582101150-r2" x="292.8" y="556.8" textLength="183" clip-path="url(#terminal-3582101150-line-22)">List all assets</text><text class="terminal-3582101150-r2" x="915" y="556.8" textLength="12.2" clip-path="url(#terminal-3582101150-line-22)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="581.2" textLength="158.6" clip-path="url(#terminal-3582101150-line-23)">list-by-alias</text><text class="terminal-3582101150-r2" x="292.8" y="581.2" textLength="268.4" clip-path="url(#terminal-3582101150-line-23)">List all asset aliases</text><text class="terminal-3582101150-r2" x="915" y="581.2" textLength="12.2" clip-path="url(#terminal-3582101150-line-23)">
+</text><text class="terminal-3582101150-r4" x="48.8" y="605.6" textLength="134.2" clip-path="url(#terminal-3582101150-line-24)">materialize</text><text class="terminal-3582101150-r2" x="292.8" y="605.6" textLength="549" clip-path="url(#terminal-3582101150-line-24)">Trigger materialization of an asset by its ID</text><text class="terminal-3582101150-r2" x="915" y="605.6" textLength="12.2" clip-path="url(#terminal-3582101150-line-24)">
+</text><text class="terminal-3582101150-r2" x="915" y="630" textLength="12.2" clip-path="url(#terminal-3582101150-line-25)">
+</text><text class="terminal-3582101150-r1" x="0" y="654.4" textLength="97.6" clip-path="url(#terminal-3582101150-line-26)">Options:</text><text class="terminal-3582101150-r2" x="915" y="654.4" textLength="12.2" clip-path="url(#terminal-3582101150-line-26)">
+</text><text class="terminal-3582101150-r4" x="24.4" y="678.8" textLength="24.4" clip-path="url(#terminal-3582101150-line-27)">-h</text><text class="terminal-3582101150-r2" x="48.8" y="678.8" textLength="24.4" clip-path="url(#terminal-3582101150-line-27)">, </text><text class="terminal-3582101150-r4" x="73.2" y="678.8" textLength="73.2" clip-path="url(#terminal-3582101150-line-27)">--help</text><text class="terminal-3582101150-r2" x="292.8" y="678.8" textLength="378.2" clip-path="ur [...]
</text>
</g>
</g>
diff --git a/airflow-ctl/docs/images/output_backfill.svg b/airflow-ctl/docs/images/output_backfill.svg
index 4119e5058af..0f3d493a89a 100644
--- a/airflow-ctl/docs/images/output_backfill.svg
+++ b/airflow-ctl/docs/images/output_backfill.svg
@@ -19,75 +19,75 @@
font-weight: 700;
}
- .terminal-602120787-matrix {
+ .terminal-3011617491-matrix {
font-family: Fira Code, monospace;
font-size: 20px;
line-height: 24.4px;
font-variant-east-asian: full-width;
}
- .terminal-602120787-title {
+ .terminal-3011617491-title {
font-size: 18px;
font-weight: bold;
font-family: arial;
}
- .terminal-602120787-r1 { fill: #ff8700 }
-.terminal-602120787-r2 { fill: #c5c8c6 }
-.terminal-602120787-r3 { fill: #808080 }
-.terminal-602120787-r4 { fill: #68a0b3 }
+ .terminal-3011617491-r1 { fill: #ff8700 }
+.terminal-3011617491-r2 { fill: #c5c8c6 }
+.terminal-3011617491-r3 { fill: #808080 }
+.terminal-3011617491-r4 { fill: #68a0b3 }
</style>
<defs>
- <clipPath id="terminal-602120787-clip-terminal">
+ <clipPath id="terminal-3011617491-clip-terminal">
<rect x="0" y="0" width="914.0" height="413.79999999999995" />
</clipPath>
- <clipPath id="terminal-602120787-line-0">
+ <clipPath id="terminal-3011617491-line-0">
<rect x="0" y="1.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-1">
+<clipPath id="terminal-3011617491-line-1">
<rect x="0" y="25.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-2">
+<clipPath id="terminal-3011617491-line-2">
<rect x="0" y="50.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-3">
+<clipPath id="terminal-3011617491-line-3">
<rect x="0" y="74.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-4">
+<clipPath id="terminal-3011617491-line-4">
<rect x="0" y="99.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-5">
+<clipPath id="terminal-3011617491-line-5">
<rect x="0" y="123.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-6">
+<clipPath id="terminal-3011617491-line-6">
<rect x="0" y="147.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-7">
+<clipPath id="terminal-3011617491-line-7">
<rect x="0" y="172.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-8">
+<clipPath id="terminal-3011617491-line-8">
<rect x="0" y="196.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-9">
+<clipPath id="terminal-3011617491-line-9">
<rect x="0" y="221.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-10">
+<clipPath id="terminal-3011617491-line-10">
<rect x="0" y="245.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-11">
+<clipPath id="terminal-3011617491-line-11">
<rect x="0" y="269.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-12">
+<clipPath id="terminal-3011617491-line-12">
<rect x="0" y="294.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-13">
+<clipPath id="terminal-3011617491-line-13">
<rect x="0" y="318.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-14">
+<clipPath id="terminal-3011617491-line-14">
<rect x="0" y="343.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-602120787-line-15">
+<clipPath id="terminal-3011617491-line-15">
<rect x="0" y="367.5" width="915" height="24.65"/>
</clipPath>
</defs>
@@ -99,26 +99,26 @@
<circle cx="44" cy="0" r="7" fill="#28c840"/>
</g>
- <g transform="translate(9, 41)" clip-path="url(#terminal-602120787-clip-terminal)">
+ <g transform="translate(9, 41)" clip-path="url(#terminal-3011617491-clip-terminal)">
- <g class="terminal-602120787-matrix">
- <text class="terminal-602120787-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-602120787-line-0)">Usage:</text><text class="terminal-602120787-r3" x="85.4" y="20" textLength="231.8" clip-path="url(#terminal-602120787-line-0)">airflowctl backfill</text><text class="terminal-602120787-r2" x="317.2" y="20" textLength="24.4" clip-path="url(#terminal-602120787-line-0)"> [</text><text class="terminal-602120787-r4" x="341.6" y="20" textLength="24.4" clip-path="url(#te [...]
-</text><text class="terminal-602120787-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-602120787-line-1)">
-</text><text class="terminal-602120787-r2" x="0" y="68.8" textLength="329.4" clip-path="url(#terminal-602120787-line-2)">Perform Backfill operations</text><text class="terminal-602120787-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-602120787-line-2)">
-</text><text class="terminal-602120787-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-602120787-line-3)">
-</text><text class="terminal-602120787-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-602120787-line-4)">Positional Arguments:</text><text class="terminal-602120787-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-602120787-line-4)">
-</text><text class="terminal-602120787-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-602120787-line-5)">COMMAND</text><text class="terminal-602120787-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-602120787-line-5)">
-</text><text class="terminal-602120787-r4" x="48.8" y="166.4" textLength="73.2" clip-path="url(#terminal-602120787-line-6)">cancel</text><text class="terminal-602120787-r2" x="219.6" y="166.4" textLength="256.2" clip-path="url(#terminal-602120787-line-6)">Cancel a backfill job</text><text class="terminal-602120787-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-602120787-line-6)">
-</text><text class="terminal-602120787-r4" x="48.8" y="190.8" textLength="73.2" clip-path="url(#terminal-602120787-line-7)">create</text><text class="terminal-602120787-r2" x="219.6" y="190.8" textLength="671" clip-path="url(#terminal-602120787-line-7)">Create a backfill job for a given DAG ID and date range</text><text class="terminal-602120787-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-602120787-line-7)">
-</text><text class="terminal-602120787-r4" x="48.8" y="215.2" textLength="170.8" clip-path="url(#terminal-602120787-line-8)">create-dry-run</text><text class="terminal-602120787-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-602120787-line-8)">
-</text><text class="terminal-602120787-r2" x="219.6" y="239.6" textLength="524.6" clip-path="url(#terminal-602120787-line-9)">Preview a backfill job without executing it</text><text class="terminal-602120787-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-602120787-line-9)">
-</text><text class="terminal-602120787-r4" x="48.8" y="264" textLength="36.6" clip-path="url(#terminal-602120787-line-10)">get</text><text class="terminal-602120787-r2" x="219.6" y="264" textLength="536.8" clip-path="url(#terminal-602120787-line-10)">Retrieve details of a backfill job by its ID</text><text class="terminal-602120787-r2" x="915" y="264" textLength="12.2" clip-path="url(#terminal-602120787-line-10)">
-</text><text class="terminal-602120787-r4" x="48.8" y="288.4" textLength="48.8" clip-path="url(#terminal-602120787-line-11)">list</text><text class="terminal-602120787-r2" x="219.6" y="288.4" textLength="463.6" clip-path="url(#terminal-602120787-line-11)">List all backfill jobs for a given DAG</text><text class="terminal-602120787-r2" x="915" y="288.4" textLength="12.2" clip-path="url(#terminal-602120787-line-11)">
-</text><text class="terminal-602120787-r4" x="48.8" y="312.8" textLength="61" clip-path="url(#terminal-602120787-line-12)">pause</text><text class="terminal-602120787-r2" x="219.6" y="312.8" textLength="341.6" clip-path="url(#terminal-602120787-line-12)">Pause an active backfill job</text><text class="terminal-602120787-r2" x="915" y="312.8" textLength="12.2" clip-path="url(#terminal-602120787-line-12)">
-</text><text class="terminal-602120787-r4" x="48.8" y="337.2" textLength="85.4" clip-path="url(#terminal-602120787-line-13)">unpause</text><text class="terminal-602120787-r2" x="219.6" y="337.2" textLength="341.6" clip-path="url(#terminal-602120787-line-13)">Resume a paused backfill job</text><text class="terminal-602120787-r2" x="915" y="337.2" textLength="12.2" clip-path="url(#terminal-602120787-line-13)">
-</text><text class="terminal-602120787-r2" x="915" y="361.6" textLength="12.2" clip-path="url(#terminal-602120787-line-14)">
-</text><text class="terminal-602120787-r1" x="0" y="386" textLength="97.6" clip-path="url(#terminal-602120787-line-15)">Options:</text><text class="terminal-602120787-r2" x="915" y="386" textLength="12.2" clip-path="url(#terminal-602120787-line-15)">
-</text><text class="terminal-602120787-r4" x="24.4" y="410.4" textLength="24.4" clip-path="url(#terminal-602120787-line-16)">-h</text><text class="terminal-602120787-r2" x="48.8" y="410.4" textLength="24.4" clip-path="url(#terminal-602120787-line-16)">, </text><text class="terminal-602120787-r4" x="73.2" y="410.4" textLength="73.2" clip-path="url(#terminal-602120787-line-16)">--help</text><text class="terminal-602120787-r2" x="219.6" y="410.4" textLength="378.2" clip-path="url(#term [...]
+ <g class="terminal-3011617491-matrix">
+ <text class="terminal-3011617491-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-3011617491-line-0)">Usage:</text><text class="terminal-3011617491-r3" x="85.4" y="20" textLength="231.8" clip-path="url(#terminal-3011617491-line-0)">airflowctl backfill</text><text class="terminal-3011617491-r2" x="317.2" y="20" textLength="24.4" clip-path="url(#terminal-3011617491-line-0)"> [</text><text class="terminal-3011617491-r4" x="341.6" y="20" textLength="24.4" clip-path=" [...]
+</text><text class="terminal-3011617491-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-3011617491-line-1)">
+</text><text class="terminal-3011617491-r2" x="0" y="68.8" textLength="329.4" clip-path="url(#terminal-3011617491-line-2)">Perform Backfill operations</text><text class="terminal-3011617491-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-3011617491-line-2)">
+</text><text class="terminal-3011617491-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-3011617491-line-3)">
+</text><text class="terminal-3011617491-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-3011617491-line-4)">Positional Arguments:</text><text class="terminal-3011617491-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-3011617491-line-4)">
+</text><text class="terminal-3011617491-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-3011617491-line-5)">COMMAND</text><text class="terminal-3011617491-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-3011617491-line-5)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="166.4" textLength="73.2" clip-path="url(#terminal-3011617491-line-6)">cancel</text><text class="terminal-3011617491-r2" x="219.6" y="166.4" textLength="256.2" clip-path="url(#terminal-3011617491-line-6)">Cancel a backfill job</text><text class="terminal-3011617491-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-3011617491-line-6)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="190.8" textLength="73.2" clip-path="url(#terminal-3011617491-line-7)">create</text><text class="terminal-3011617491-r2" x="219.6" y="190.8" textLength="671" clip-path="url(#terminal-3011617491-line-7)">Create a backfill job for a given Dag ID and date range</text><text class="terminal-3011617491-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-3011617491-line-7)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="215.2" textLength="170.8" clip-path="url(#terminal-3011617491-line-8)">create-dry-run</text><text class="terminal-3011617491-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-3011617491-line-8)">
+</text><text class="terminal-3011617491-r2" x="219.6" y="239.6" textLength="524.6" clip-path="url(#terminal-3011617491-line-9)">Preview a backfill job without executing it</text><text class="terminal-3011617491-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-3011617491-line-9)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="264" textLength="36.6" clip-path="url(#terminal-3011617491-line-10)">get</text><text class="terminal-3011617491-r2" x="219.6" y="264" textLength="536.8" clip-path="url(#terminal-3011617491-line-10)">Retrieve details of a backfill job by its ID</text><text class="terminal-3011617491-r2" x="915" y="264" textLength="12.2" clip-path="url(#terminal-3011617491-line-10)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="288.4" textLength="48.8" clip-path="url(#terminal-3011617491-line-11)">list</text><text class="terminal-3011617491-r2" x="219.6" y="288.4" textLength="463.6" clip-path="url(#terminal-3011617491-line-11)">List all backfill jobs for a given Dag</text><text class="terminal-3011617491-r2" x="915" y="288.4" textLength="12.2" clip-path="url(#terminal-3011617491-line-11)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="312.8" textLength="61" clip-path="url(#terminal-3011617491-line-12)">pause</text><text class="terminal-3011617491-r2" x="219.6" y="312.8" textLength="341.6" clip-path="url(#terminal-3011617491-line-12)">Pause an active backfill job</text><text class="terminal-3011617491-r2" x="915" y="312.8" textLength="12.2" clip-path="url(#terminal-3011617491-line-12)">
+</text><text class="terminal-3011617491-r4" x="48.8" y="337.2" textLength="85.4" clip-path="url(#terminal-3011617491-line-13)">unpause</text><text class="terminal-3011617491-r2" x="219.6" y="337.2" textLength="341.6" clip-path="url(#terminal-3011617491-line-13)">Resume a paused backfill job</text><text class="terminal-3011617491-r2" x="915" y="337.2" textLength="12.2" clip-path="url(#terminal-3011617491-line-13)">
+</text><text class="terminal-3011617491-r2" x="915" y="361.6" textLength="12.2" clip-path="url(#terminal-3011617491-line-14)">
+</text><text class="terminal-3011617491-r1" x="0" y="386" textLength="97.6" clip-path="url(#terminal-3011617491-line-15)">Options:</text><text class="terminal-3011617491-r2" x="915" y="386" textLength="12.2" clip-path="url(#terminal-3011617491-line-15)">
+</text><text class="terminal-3011617491-r4" x="24.4" y="410.4" textLength="24.4" clip-path="url(#terminal-3011617491-line-16)">-h</text><text class="terminal-3011617491-r2" x="48.8" y="410.4" textLength="24.4" clip-path="url(#terminal-3011617491-line-16)">, </text><text class="terminal-3011617491-r4" x="73.2" y="410.4" textLength="73.2" clip-path="url(#terminal-3011617491-line-16)">--help</text><text class="terminal-3011617491-r2" x="219.6" y="410.4" textLength="378.2" clip-path="ur [...]
</text>
</g>
</g>
diff --git a/airflow-ctl/docs/images/output_dagrun.svg b/airflow-ctl/docs/images/output_dagrun.svg
index a03fb094b3e..48e96c89420 100644
--- a/airflow-ctl/docs/images/output_dagrun.svg
+++ b/airflow-ctl/docs/images/output_dagrun.svg
@@ -19,57 +19,57 @@
font-weight: 700;
}
- .terminal-3797102828-matrix {
+ .terminal-3834720684-matrix {
font-family: Fira Code, monospace;
font-size: 20px;
line-height: 24.4px;
font-variant-east-asian: full-width;
}
- .terminal-3797102828-title {
+ .terminal-3834720684-title {
font-size: 18px;
font-weight: bold;
font-family: arial;
}
- .terminal-3797102828-r1 { fill: #ff8700 }
-.terminal-3797102828-r2 { fill: #c5c8c6 }
-.terminal-3797102828-r3 { fill: #808080 }
-.terminal-3797102828-r4 { fill: #68a0b3 }
+ .terminal-3834720684-r1 { fill: #ff8700 }
+.terminal-3834720684-r2 { fill: #c5c8c6 }
+.terminal-3834720684-r3 { fill: #808080 }
+.terminal-3834720684-r4 { fill: #68a0b3 }
</style>
<defs>
- <clipPath id="terminal-3797102828-clip-terminal">
+ <clipPath id="terminal-3834720684-clip-terminal">
<rect x="0" y="0" width="914.0" height="267.4" />
</clipPath>
- <clipPath id="terminal-3797102828-line-0">
+ <clipPath id="terminal-3834720684-line-0">
<rect x="0" y="1.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-1">
+<clipPath id="terminal-3834720684-line-1">
<rect x="0" y="25.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-2">
+<clipPath id="terminal-3834720684-line-2">
<rect x="0" y="50.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-3">
+<clipPath id="terminal-3834720684-line-3">
<rect x="0" y="74.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-4">
+<clipPath id="terminal-3834720684-line-4">
<rect x="0" y="99.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-5">
+<clipPath id="terminal-3834720684-line-5">
<rect x="0" y="123.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-6">
+<clipPath id="terminal-3834720684-line-6">
<rect x="0" y="147.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-7">
+<clipPath id="terminal-3834720684-line-7">
<rect x="0" y="172.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-8">
+<clipPath id="terminal-3834720684-line-8">
<rect x="0" y="196.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-3797102828-line-9">
+<clipPath id="terminal-3834720684-line-9">
<rect x="0" y="221.1" width="915" height="24.65"/>
</clipPath>
</defs>
@@ -81,20 +81,20 @@
<circle cx="44" cy="0" r="7" fill="#28c840"/>
</g>
- <g transform="translate(9, 41)" clip-path="url(#terminal-3797102828-clip-terminal)">
+ <g transform="translate(9, 41)" clip-path="url(#terminal-3834720684-clip-terminal)">
- <g class="terminal-3797102828-matrix">
- <text class="terminal-3797102828-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-3797102828-line-0)">Usage:</text><text class="terminal-3797102828-r3" x="85.4" y="20" textLength="207.4" clip-path="url(#terminal-3797102828-line-0)">airflowctl dagrun</text><text class="terminal-3797102828-r2" x="292.8" y="20" textLength="24.4" clip-path="url(#terminal-3797102828-line-0)"> [</text><text class="terminal-3797102828-r4" x="317.2" y="20" textLength="24.4" clip-path="ur [...]
-</text><text class="terminal-3797102828-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-3797102828-line-1)">
-</text><text class="terminal-3797102828-r2" x="0" y="68.8" textLength="305" clip-path="url(#terminal-3797102828-line-2)">Perform DagRun operations</text><text class="terminal-3797102828-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-3797102828-line-2)">
-</text><text class="terminal-3797102828-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-3797102828-line-3)">
-</text><text class="terminal-3797102828-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-3797102828-line-4)">Positional Arguments:</text><text class="terminal-3797102828-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-3797102828-line-4)">
-</text><text class="terminal-3797102828-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-3797102828-line-5)">COMMAND</text><text class="terminal-3797102828-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-3797102828-line-5)">
-</text><text class="terminal-3797102828-r4" x="48.8" y="166.4" textLength="36.6" clip-path="url(#terminal-3797102828-line-6)">get</text><text class="terminal-3797102828-r2" x="170.8" y="166.4" textLength="475.8" clip-path="url(#terminal-3797102828-line-6)">Retrieve a DAG run by DAG ID and run ID</text><text class="terminal-3797102828-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-3797102828-line-6)">
-</text><text class="terminal-3797102828-r4" x="48.8" y="190.8" textLength="48.8" clip-path="url(#terminal-3797102828-line-7)">list</text><text class="terminal-3797102828-r2" x="170.8" y="190.8" textLength="707.6" clip-path="url(#terminal-3797102828-line-7)">List DAG runs, optionally filtered by state and date range</text><text class="terminal-3797102828-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-3797102828-line-7)">
-</text><text class="terminal-3797102828-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-3797102828-line-8)">
-</text><text class="terminal-3797102828-r1" x="0" y="239.6" textLength="97.6" clip-path="url(#terminal-3797102828-line-9)">Options:</text><text class="terminal-3797102828-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-3797102828-line-9)">
-</text><text class="terminal-3797102828-r4" x="24.4" y="264" textLength="24.4" clip-path="url(#terminal-3797102828-line-10)">-h</text><text class="terminal-3797102828-r2" x="48.8" y="264" textLength="24.4" clip-path="url(#terminal-3797102828-line-10)">, </text><text class="terminal-3797102828-r4" x="73.2" y="264" textLength="73.2" clip-path="url(#terminal-3797102828-line-10)">--help</text><text class="terminal-3797102828-r2" x="170.8" y="264" textLength="378.2" clip-path="url(#termi [...]
+ <g class="terminal-3834720684-matrix">
+ <text class="terminal-3834720684-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-3834720684-line-0)">Usage:</text><text class="terminal-3834720684-r3" x="85.4" y="20" textLength="207.4" clip-path="url(#terminal-3834720684-line-0)">airflowctl dagrun</text><text class="terminal-3834720684-r2" x="292.8" y="20" textLength="24.4" clip-path="url(#terminal-3834720684-line-0)"> [</text><text class="terminal-3834720684-r4" x="317.2" y="20" textLength="24.4" clip-path="ur [...]
+</text><text class="terminal-3834720684-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-3834720684-line-1)">
+</text><text class="terminal-3834720684-r2" x="0" y="68.8" textLength="305" clip-path="url(#terminal-3834720684-line-2)">Perform DagRun operations</text><text class="terminal-3834720684-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-3834720684-line-2)">
+</text><text class="terminal-3834720684-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-3834720684-line-3)">
+</text><text class="terminal-3834720684-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-3834720684-line-4)">Positional Arguments:</text><text class="terminal-3834720684-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-3834720684-line-4)">
+</text><text class="terminal-3834720684-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-3834720684-line-5)">COMMAND</text><text class="terminal-3834720684-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-3834720684-line-5)">
+</text><text class="terminal-3834720684-r4" x="48.8" y="166.4" textLength="36.6" clip-path="url(#terminal-3834720684-line-6)">get</text><text class="terminal-3834720684-r2" x="170.8" y="166.4" textLength="475.8" clip-path="url(#terminal-3834720684-line-6)">Retrieve a Dag run by Dag ID and run ID</text><text class="terminal-3834720684-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-3834720684-line-6)">
+</text><text class="terminal-3834720684-r4" x="48.8" y="190.8" textLength="48.8" clip-path="url(#terminal-3834720684-line-7)">list</text><text class="terminal-3834720684-r2" x="170.8" y="190.8" textLength="707.6" clip-path="url(#terminal-3834720684-line-7)">List Dag runs, optionally filtered by state and date range</text><text class="terminal-3834720684-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-3834720684-line-7)">
+</text><text class="terminal-3834720684-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-3834720684-line-8)">
+</text><text class="terminal-3834720684-r1" x="0" y="239.6" textLength="97.6" clip-path="url(#terminal-3834720684-line-9)">Options:</text><text class="terminal-3834720684-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-3834720684-line-9)">
+</text><text class="terminal-3834720684-r4" x="24.4" y="264" textLength="24.4" clip-path="url(#terminal-3834720684-line-10)">-h</text><text class="terminal-3834720684-r2" x="48.8" y="264" textLength="24.4" clip-path="url(#terminal-3834720684-line-10)">, </text><text class="terminal-3834720684-r4" x="73.2" y="264" textLength="73.2" clip-path="url(#terminal-3834720684-line-10)">--help</text><text class="terminal-3834720684-r2" x="170.8" y="264" textLength="378.2" clip-path="url(#termi [...]
</text>
</g>
</g>
diff --git a/airflow-ctl/docs/images/output_dags.svg b/airflow-ctl/docs/images/output_dags.svg
index 0bbe6f479d7..f38d12d60e3 100644
--- a/airflow-ctl/docs/images/output_dags.svg
+++ b/airflow-ctl/docs/images/output_dags.svg
@@ -19,99 +19,99 @@
font-weight: 700;
}
- .terminal-1967506512-matrix {
+ .terminal-3628713872-matrix {
font-family: Fira Code, monospace;
font-size: 20px;
line-height: 24.4px;
font-variant-east-asian: full-width;
}
- .terminal-1967506512-title {
+ .terminal-3628713872-title {
font-size: 18px;
font-weight: bold;
font-family: arial;
}
- .terminal-1967506512-r1 { fill: #ff8700 }
-.terminal-1967506512-r2 { fill: #c5c8c6 }
-.terminal-1967506512-r3 { fill: #808080 }
-.terminal-1967506512-r4 { fill: #68a0b3 }
+ .terminal-3628713872-r1 { fill: #ff8700 }
+.terminal-3628713872-r2 { fill: #c5c8c6 }
+.terminal-3628713872-r3 { fill: #808080 }
+.terminal-3628713872-r4 { fill: #68a0b3 }
</style>
<defs>
- <clipPath id="terminal-1967506512-clip-terminal">
+ <clipPath id="terminal-3628713872-clip-terminal">
<rect x="0" y="0" width="914.0" height="609.0" />
</clipPath>
- <clipPath id="terminal-1967506512-line-0">
+ <clipPath id="terminal-3628713872-line-0">
<rect x="0" y="1.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-1">
+<clipPath id="terminal-3628713872-line-1">
<rect x="0" y="25.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-2">
+<clipPath id="terminal-3628713872-line-2">
<rect x="0" y="50.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-3">
+<clipPath id="terminal-3628713872-line-3">
<rect x="0" y="74.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-4">
+<clipPath id="terminal-3628713872-line-4">
<rect x="0" y="99.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-5">
+<clipPath id="terminal-3628713872-line-5">
<rect x="0" y="123.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-6">
+<clipPath id="terminal-3628713872-line-6">
<rect x="0" y="147.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-7">
+<clipPath id="terminal-3628713872-line-7">
<rect x="0" y="172.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-8">
+<clipPath id="terminal-3628713872-line-8">
<rect x="0" y="196.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-9">
+<clipPath id="terminal-3628713872-line-9">
<rect x="0" y="221.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-10">
+<clipPath id="terminal-3628713872-line-10">
<rect x="0" y="245.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-11">
+<clipPath id="terminal-3628713872-line-11">
<rect x="0" y="269.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-12">
+<clipPath id="terminal-3628713872-line-12">
<rect x="0" y="294.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-13">
+<clipPath id="terminal-3628713872-line-13">
<rect x="0" y="318.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-14">
+<clipPath id="terminal-3628713872-line-14">
<rect x="0" y="343.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-15">
+<clipPath id="terminal-3628713872-line-15">
<rect x="0" y="367.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-16">
+<clipPath id="terminal-3628713872-line-16">
<rect x="0" y="391.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-17">
+<clipPath id="terminal-3628713872-line-17">
<rect x="0" y="416.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-18">
+<clipPath id="terminal-3628713872-line-18">
<rect x="0" y="440.7" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-19">
+<clipPath id="terminal-3628713872-line-19">
<rect x="0" y="465.1" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-20">
+<clipPath id="terminal-3628713872-line-20">
<rect x="0" y="489.5" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-21">
+<clipPath id="terminal-3628713872-line-21">
<rect x="0" y="513.9" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-22">
+<clipPath id="terminal-3628713872-line-22">
<rect x="0" y="538.3" width="915" height="24.65"/>
</clipPath>
-<clipPath id="terminal-1967506512-line-23">
+<clipPath id="terminal-3628713872-line-23">
<rect x="0" y="562.7" width="915" height="24.65"/>
</clipPath>
</defs>
@@ -123,34 +123,34 @@
<circle cx="44" cy="0" r="7" fill="#28c840"/>
</g>
- <g transform="translate(9, 41)" clip-path="url(#terminal-1967506512-clip-terminal)">
+ <g transform="translate(9, 41)" clip-path="url(#terminal-3628713872-clip-terminal)">
- <g class="terminal-1967506512-matrix">
- <text class="terminal-1967506512-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-1967506512-line-0)">Usage:</text><text class="terminal-1967506512-r3" x="85.4" y="20" textLength="183" clip-path="url(#terminal-1967506512-line-0)">airflowctl dags</text><text class="terminal-1967506512-r2" x="268.4" y="20" textLength="24.4" clip-path="url(#terminal-1967506512-line-0)"> [</text><text class="terminal-1967506512-r4" x="292.8" y="20" textLength="24.4" clip-path="url(#t [...]
-</text><text class="terminal-1967506512-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-1967506512-line-1)">
-</text><text class="terminal-1967506512-r2" x="0" y="68.8" textLength="280.6" clip-path="url(#terminal-1967506512-line-2)">Perform Dags operations</text><text class="terminal-1967506512-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-1967506512-line-2)">
-</text><text class="terminal-1967506512-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-1967506512-line-3)">
-</text><text class="terminal-1967506512-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-1967506512-line-4)">Positional Arguments:</text><text class="terminal-1967506512-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-1967506512-line-4)">
-</text><text class="terminal-1967506512-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-1967506512-line-5)">COMMAND</text><text class="terminal-1967506512-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-1967506512-line-5)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="166.4" textLength="73.2" clip-path="url(#terminal-1967506512-line-6)">delete</text><text class="terminal-1967506512-r2" x="268.4" y="166.4" textLength="268.4" clip-path="url(#terminal-1967506512-line-6)">Delete a DAG by its ID</text><text class="terminal-1967506512-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-1967506512-line-6)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="190.8" textLength="36.6" clip-path="url(#terminal-1967506512-line-7)">get</text><text class="terminal-1967506512-r2" x="268.4" y="190.8" textLength="292.8" clip-path="url(#terminal-1967506512-line-7)">Retrieve a DAG by its ID</text><text class="terminal-1967506512-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-1967506512-line-7)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="215.2" textLength="134.2" clip-path="url(#terminal-1967506512-line-8)">get-details</text><text class="terminal-1967506512-r2" x="268.4" y="215.2" textLength="475.8" clip-path="url(#terminal-1967506512-line-8)">Retrieve detailed information for a DAG</text><text class="terminal-1967506512-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-1967506512-line-8)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="239.6" textLength="195.2" clip-path="url(#terminal-1967506512-line-9)">get-import-error</text><text class="terminal-1967506512-r2" x="268.4" y="239.6" textLength="451.4" clip-path="url(#terminal-1967506512-line-9)">Retrieve a DAG import error by its ID</text><text class="terminal-1967506512-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-1967506512-line-9)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="264" textLength="109.8" clip-path="url(#terminal-1967506512-line-10)">get-stats</text><text class="terminal-1967506512-r2" x="268.4" y="264" textLength="536.8" clip-path="url(#terminal-1967506512-line-10)">Retrieve run statistics for one or more DAGs</text><text class="terminal-1967506512-r2" x="915" y="264" textLength="12.2" clip-path="url(#terminal-1967506512-line-10)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="288.4" textLength="97.6" clip-path="url(#terminal-1967506512-line-11)">get-tags</text><text class="terminal-1967506512-r2" x="268.4" y="288.4" textLength="366" clip-path="url(#terminal-1967506512-line-11)">List all tags used across DAGs</text><text class="terminal-1967506512-r2" x="915" y="288.4" textLength="12.2" clip-path="url(#terminal-1967506512-line-11)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="312.8" textLength="134.2" clip-path="url(#terminal-1967506512-line-12)">get-version</text><text class="terminal-1967506512-r2" x="268.4" y="312.8" textLength="439.2" clip-path="url(#terminal-1967506512-line-12)">Retrieve a specific version of a DAG</text><text class="terminal-1967506512-r2" x="915" y="312.8" textLength="12.2" clip-path="url(#terminal-1967506512-line-12)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="337.2" textLength="48.8" clip-path="url(#terminal-1967506512-line-13)">list</text><text class="terminal-1967506512-r2" x="268.4" y="337.2" textLength="158.6" clip-path="url(#terminal-1967506512-line-13)">List all DAGs</text><text class="terminal-1967506512-r2" x="915" y="337.2" textLength="12.2" clip-path="url(#terminal-1967506512-line-13)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="361.6" textLength="219.6" clip-path="url(#terminal-1967506512-line-14)">list-import-errors</text><text class="terminal-1967506512-r2" x="915" y="361.6" textLength="12.2" clip-path="url(#terminal-1967506512-line-14)">
-</text><text class="terminal-1967506512-r2" x="268.4" y="386" textLength="317.2" clip-path="url(#terminal-1967506512-line-15)">List all DAG import errors</text><text class="terminal-1967506512-r2" x="915" y="386" textLength="12.2" clip-path="url(#terminal-1967506512-line-15)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="410.4" textLength="146.4" clip-path="url(#terminal-1967506512-line-16)">list-version</text><text class="terminal-1967506512-r2" x="268.4" y="410.4" textLength="317.2" clip-path="url(#terminal-1967506512-line-16)">List all versions of a DAG</text><text class="terminal-1967506512-r2" x="915" y="410.4" textLength="12.2" clip-path="url(#terminal-1967506512-line-16)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="434.8" textLength="146.4" clip-path="url(#terminal-1967506512-line-17)">list-warning</text><text class="terminal-1967506512-r2" x="268.4" y="434.8" textLength="256.2" clip-path="url(#terminal-1967506512-line-17)">List all DAG warnings</text><text class="terminal-1967506512-r2" x="915" y="434.8" textLength="12.2" clip-path="url(#terminal-1967506512-line-17)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="459.2" textLength="61" clip-path="url(#terminal-1967506512-line-18)">pause</text><text class="terminal-1967506512-r2" x="268.4" y="459.2" textLength="134.2" clip-path="url(#terminal-1967506512-line-18)">Pause a Dag</text><text class="terminal-1967506512-r2" x="915" y="459.2" textLength="12.2" clip-path="url(#terminal-1967506512-line-18)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="483.6" textLength="85.4" clip-path="url(#terminal-1967506512-line-19)">trigger</text><text class="terminal-1967506512-r2" x="268.4" y="483.6" textLength="256.2" clip-path="url(#terminal-1967506512-line-19)">Trigger a new DAG run</text><text class="terminal-1967506512-r2" x="915" y="483.6" textLength="12.2" clip-path="url(#terminal-1967506512-line-19)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="508" textLength="85.4" clip-path="url(#terminal-1967506512-line-20)">unpause</text><text class="terminal-1967506512-r2" x="268.4" y="508" textLength="158.6" clip-path="url(#terminal-1967506512-line-20)">Unpause a Dag</text><text class="terminal-1967506512-r2" x="915" y="508" textLength="12.2" clip-path="url(#terminal-1967506512-line-20)">
-</text><text class="terminal-1967506512-r4" x="48.8" y="532.4" textLength="73.2" clip-path="url(#terminal-1967506512-line-21)">update</text><text class="terminal-1967506512-r2" x="268.4" y="532.4" textLength="317.2" clip-path="url(#terminal-1967506512-line-21)">Update properties of a DAG</text><text class="terminal-1967506512-r2" x="915" y="532.4" textLength="12.2" clip-path="url(#terminal-1967506512-line-21)">
-</text><text class="terminal-1967506512-r2" x="915" y="556.8" textLength="12.2" clip-path="url(#terminal-1967506512-line-22)">
-</text><text class="terminal-1967506512-r1" x="0" y="581.2" textLength="97.6" clip-path="url(#terminal-1967506512-line-23)">Options:</text><text class="terminal-1967506512-r2" x="915" y="581.2" textLength="12.2" clip-path="url(#terminal-1967506512-line-23)">
-</text><text class="terminal-1967506512-r4" x="24.4" y="605.6" textLength="24.4" clip-path="url(#terminal-1967506512-line-24)">-h</text><text class="terminal-1967506512-r2" x="48.8" y="605.6" textLength="24.4" clip-path="url(#terminal-1967506512-line-24)">, </text><text class="terminal-1967506512-r4" x="73.2" y="605.6" textLength="73.2" clip-path="url(#terminal-1967506512-line-24)">--help</text><text class="terminal-1967506512-r2" x="268.4" y="605.6" textLength="378.2" clip-path="ur [...]
+ <g class="terminal-3628713872-matrix">
+ <text class="terminal-3628713872-r1" x="0" y="20" textLength="73.2" clip-path="url(#terminal-3628713872-line-0)">Usage:</text><text class="terminal-3628713872-r3" x="85.4" y="20" textLength="183" clip-path="url(#terminal-3628713872-line-0)">airflowctl dags</text><text class="terminal-3628713872-r2" x="268.4" y="20" textLength="24.4" clip-path="url(#terminal-3628713872-line-0)"> [</text><text class="terminal-3628713872-r4" x="292.8" y="20" textLength="24.4" clip-path="url(#t [...]
+</text><text class="terminal-3628713872-r2" x="915" y="44.4" textLength="12.2" clip-path="url(#terminal-3628713872-line-1)">
+</text><text class="terminal-3628713872-r2" x="0" y="68.8" textLength="280.6" clip-path="url(#terminal-3628713872-line-2)">Perform Dags operations</text><text class="terminal-3628713872-r2" x="915" y="68.8" textLength="12.2" clip-path="url(#terminal-3628713872-line-2)">
+</text><text class="terminal-3628713872-r2" x="915" y="93.2" textLength="12.2" clip-path="url(#terminal-3628713872-line-3)">
+</text><text class="terminal-3628713872-r1" x="0" y="117.6" textLength="256.2" clip-path="url(#terminal-3628713872-line-4)">Positional Arguments:</text><text class="terminal-3628713872-r2" x="915" y="117.6" textLength="12.2" clip-path="url(#terminal-3628713872-line-4)">
+</text><text class="terminal-3628713872-r4" x="24.4" y="142" textLength="85.4" clip-path="url(#terminal-3628713872-line-5)">COMMAND</text><text class="terminal-3628713872-r2" x="915" y="142" textLength="12.2" clip-path="url(#terminal-3628713872-line-5)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="166.4" textLength="73.2" clip-path="url(#terminal-3628713872-line-6)">delete</text><text class="terminal-3628713872-r2" x="268.4" y="166.4" textLength="268.4" clip-path="url(#terminal-3628713872-line-6)">Delete a Dag by its ID</text><text class="terminal-3628713872-r2" x="915" y="166.4" textLength="12.2" clip-path="url(#terminal-3628713872-line-6)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="190.8" textLength="36.6" clip-path="url(#terminal-3628713872-line-7)">get</text><text class="terminal-3628713872-r2" x="268.4" y="190.8" textLength="292.8" clip-path="url(#terminal-3628713872-line-7)">Retrieve a Dag by its ID</text><text class="terminal-3628713872-r2" x="915" y="190.8" textLength="12.2" clip-path="url(#terminal-3628713872-line-7)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="215.2" textLength="134.2" clip-path="url(#terminal-3628713872-line-8)">get-details</text><text class="terminal-3628713872-r2" x="268.4" y="215.2" textLength="475.8" clip-path="url(#terminal-3628713872-line-8)">Retrieve detailed information for a Dag</text><text class="terminal-3628713872-r2" x="915" y="215.2" textLength="12.2" clip-path="url(#terminal-3628713872-line-8)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="239.6" textLength="195.2" clip-path="url(#terminal-3628713872-line-9)">get-import-error</text><text class="terminal-3628713872-r2" x="268.4" y="239.6" textLength="451.4" clip-path="url(#terminal-3628713872-line-9)">Retrieve a Dag import error by its ID</text><text class="terminal-3628713872-r2" x="915" y="239.6" textLength="12.2" clip-path="url(#terminal-3628713872-line-9)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="264" textLength="109.8" clip-path="url(#terminal-3628713872-line-10)">get-stats</text><text class="terminal-3628713872-r2" x="268.4" y="264" textLength="536.8" clip-path="url(#terminal-3628713872-line-10)">Retrieve run statistics for one or more Dags</text><text class="terminal-3628713872-r2" x="915" y="264" textLength="12.2" clip-path="url(#terminal-3628713872-line-10)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="288.4" textLength="97.6" clip-path="url(#terminal-3628713872-line-11)">get-tags</text><text class="terminal-3628713872-r2" x="268.4" y="288.4" textLength="366" clip-path="url(#terminal-3628713872-line-11)">List all tags used across Dags</text><text class="terminal-3628713872-r2" x="915" y="288.4" textLength="12.2" clip-path="url(#terminal-3628713872-line-11)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="312.8" textLength="134.2" clip-path="url(#terminal-3628713872-line-12)">get-version</text><text class="terminal-3628713872-r2" x="268.4" y="312.8" textLength="439.2" clip-path="url(#terminal-3628713872-line-12)">Retrieve a specific version of a Dag</text><text class="terminal-3628713872-r2" x="915" y="312.8" textLength="12.2" clip-path="url(#terminal-3628713872-line-12)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="337.2" textLength="48.8" clip-path="url(#terminal-3628713872-line-13)">list</text><text class="terminal-3628713872-r2" x="268.4" y="337.2" textLength="158.6" clip-path="url(#terminal-3628713872-line-13)">List all Dags</text><text class="terminal-3628713872-r2" x="915" y="337.2" textLength="12.2" clip-path="url(#terminal-3628713872-line-13)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="361.6" textLength="219.6" clip-path="url(#terminal-3628713872-line-14)">list-import-errors</text><text class="terminal-3628713872-r2" x="915" y="361.6" textLength="12.2" clip-path="url(#terminal-3628713872-line-14)">
+</text><text class="terminal-3628713872-r2" x="268.4" y="386" textLength="317.2" clip-path="url(#terminal-3628713872-line-15)">List all Dag import errors</text><text class="terminal-3628713872-r2" x="915" y="386" textLength="12.2" clip-path="url(#terminal-3628713872-line-15)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="410.4" textLength="146.4" clip-path="url(#terminal-3628713872-line-16)">list-version</text><text class="terminal-3628713872-r2" x="268.4" y="410.4" textLength="317.2" clip-path="url(#terminal-3628713872-line-16)">List all versions of a Dag</text><text class="terminal-3628713872-r2" x="915" y="410.4" textLength="12.2" clip-path="url(#terminal-3628713872-line-16)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="434.8" textLength="146.4" clip-path="url(#terminal-3628713872-line-17)">list-warning</text><text class="terminal-3628713872-r2" x="268.4" y="434.8" textLength="256.2" clip-path="url(#terminal-3628713872-line-17)">List all Dag warnings</text><text class="terminal-3628713872-r2" x="915" y="434.8" textLength="12.2" clip-path="url(#terminal-3628713872-line-17)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="459.2" textLength="61" clip-path="url(#terminal-3628713872-line-18)">pause</text><text class="terminal-3628713872-r2" x="268.4" y="459.2" textLength="134.2" clip-path="url(#terminal-3628713872-line-18)">Pause a Dag</text><text class="terminal-3628713872-r2" x="915" y="459.2" textLength="12.2" clip-path="url(#terminal-3628713872-line-18)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="483.6" textLength="85.4" clip-path="url(#terminal-3628713872-line-19)">trigger</text><text class="terminal-3628713872-r2" x="268.4" y="483.6" textLength="256.2" clip-path="url(#terminal-3628713872-line-19)">Trigger a new Dag run</text><text class="terminal-3628713872-r2" x="915" y="483.6" textLength="12.2" clip-path="url(#terminal-3628713872-line-19)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="508" textLength="85.4" clip-path="url(#terminal-3628713872-line-20)">unpause</text><text class="terminal-3628713872-r2" x="268.4" y="508" textLength="158.6" clip-path="url(#terminal-3628713872-line-20)">Unpause a Dag</text><text class="terminal-3628713872-r2" x="915" y="508" textLength="12.2" clip-path="url(#terminal-3628713872-line-20)">
+</text><text class="terminal-3628713872-r4" x="48.8" y="532.4" textLength="73.2" clip-path="url(#terminal-3628713872-line-21)">update</text><text class="terminal-3628713872-r2" x="268.4" y="532.4" textLength="317.2" clip-path="url(#terminal-3628713872-line-21)">Update properties of a Dag</text><text class="terminal-3628713872-r2" x="915" y="532.4" textLength="12.2" clip-path="url(#terminal-3628713872-line-21)">
+</text><text class="terminal-3628713872-r2" x="915" y="556.8" textLength="12.2" clip-path="url(#terminal-3628713872-line-22)">
+</text><text class="terminal-3628713872-r1" x="0" y="581.2" textLength="97.6" clip-path="url(#terminal-3628713872-line-23)">Options:</text><text class="terminal-3628713872-r2" x="915" y="581.2" textLength="12.2" clip-path="url(#terminal-3628713872-line-23)">
+</text><text class="terminal-3628713872-r4" x="24.4" y="605.6" textLength="24.4" clip-path="url(#terminal-3628713872-line-24)">-h</text><text class="terminal-3628713872-r2" x="48.8" y="605.6" textLength="24.4" clip-path="url(#terminal-3628713872-line-24)">, </text><text class="terminal-3628713872-r4" x="73.2" y="605.6" textLength="73.2" clip-path="url(#terminal-3628713872-line-24)">--help</text><text class="terminal-3628713872-r2" x="268.4" y="605.6" textLength="378.2" clip-path="ur [...]
</text>
</g>
</g>
diff --git a/airflow-ctl/src/airflowctl/api/client.py b/airflow-ctl/src/airflowctl/api/client.py
index e4c5ddf2302..b01200fac1c 100644
--- a/airflow-ctl/src/airflowctl/api/client.py
+++ b/airflow-ctl/src/airflowctl/api/client.py
@@ -422,13 +422,13 @@ class Client(httpx.Client):
@lru_cache() # type: ignore[prop-decorator]
@property
def dags(self):
- """Operations related to DAGs."""
+ """Operations related to Dags."""
return DagsOperations(self)
@lru_cache() # type: ignore[prop-decorator]
@property
def dag_runs(self):
- """Operations related to DAG runs."""
+ """Operations related to Dag runs."""
return DagRunOperations(self)
@lru_cache() # type: ignore[prop-decorator]
diff --git a/airflow-ctl/src/airflowctl/api/datamodels/generated.py b/airflow-ctl/src/airflowctl/api/datamodels/generated.py
index de32ad017b3..276c8699de0 100644
--- a/airflow-ctl/src/airflowctl/api/datamodels/generated.py
+++ b/airflow-ctl/src/airflowctl/api/datamodels/generated.py
@@ -280,7 +280,7 @@ class DAGPatchBody(BaseModel):
class DAGRunClearBody(BaseModel):
"""
- DAG Run serializer for clear endpoint body.
+ Dag Run serializer for clear endpoint body.
"""
model_config = ConfigDict(
@@ -291,7 +291,7 @@ class DAGRunClearBody(BaseModel):
only_new: Annotated[
bool | None,
Field(
- description="Only queue newly added tasks in the latest DAG version without clearing existing tasks.",
+ description="Only queue newly added tasks in the latest Dag version without clearing existing tasks.",
title="Only New",
),
] = False
@@ -306,7 +306,7 @@ class DAGRunClearBody(BaseModel):
class DAGRunPatchStates(str, Enum):
"""
- Enum for DAG Run states when updating a DAG Run.
+ Enum for Dag Run states when updating a Dag Run.
"""
QUEUED = "queued"
@@ -316,7 +316,7 @@ class DAGRunPatchStates(str, Enum):
class DAGSourceResponse(BaseModel):
"""
- DAG Source serializer for responses.
+ Dag Source serializer for responses.
"""
content: Annotated[str | None, Field(title="Content")] = None
@@ -327,7 +327,7 @@ class DAGSourceResponse(BaseModel):
class DAGTagCollectionResponse(BaseModel):
"""
- DAG Tags Collection serializer for responses.
+ Dag Tags Collection serializer for responses.
"""
tags: Annotated[list[str], Field(title="Tags")]
@@ -409,7 +409,7 @@ class DagRunType(str, Enum):
class DagScheduleAssetReference(BaseModel):
"""
- DAG schedule reference serializer for assets.
+ Dag schedule reference serializer for assets.
"""
model_config = ConfigDict(
@@ -431,7 +431,7 @@ class DagStatsStateResponse(BaseModel):
class DagTagResponse(BaseModel):
"""
- DAG Tag serializer for responses.
+ Dag Tag serializer for responses.
"""
name: Annotated[str, Field(title="Name")]
@@ -919,7 +919,7 @@ class TimeDelta(BaseModel):
class TriggerDAGRunPostBody(BaseModel):
"""
- Trigger DAG Run Serializer for POST body.
+ Trigger Dag Run Serializer for POST body.
"""
model_config = ConfigDict(
@@ -1376,7 +1376,7 @@ class ConnectionCollectionResponse(BaseModel):
class DAGDetailsResponse(BaseModel):
"""
- Specific serializer for DAG Details responses.
+ Specific serializer for Dag Details responses.
"""
dag_id: Annotated[str, Field(title="Dag Id")]
@@ -1428,7 +1428,7 @@ class DAGDetailsResponse(BaseModel):
is_favorite: Annotated[bool | None, Field(title="Is Favorite")] = False
active_runs_count: Annotated[int | None, Field(title="Active Runs Count")] = 0
is_backfillable: Annotated[
- bool, Field(description="Whether this DAG's schedule supports backfilling.", title="Is Backfillable")
+ bool, Field(description="Whether this Dag's schedule supports backfilling.", title="Is Backfillable")
]
file_token: Annotated[str, Field(description="Return file token.", title="File Token")]
concurrency: Annotated[
@@ -1445,7 +1445,7 @@ class DAGDetailsResponse(BaseModel):
class DAGResponse(BaseModel):
"""
- DAG serializer for responses.
+ Dag serializer for responses.
"""
dag_id: Annotated[str, Field(title="Dag Id")]
@@ -1481,14 +1481,14 @@ class DAGResponse(BaseModel):
allowed_run_types: Annotated[list[DagRunType] | None, Field(title="Allowed Run Types")] = None
owners: Annotated[list[str], Field(title="Owners")]
is_backfillable: Annotated[
- bool, Field(description="Whether this DAG's schedule supports backfilling.", title="Is Backfillable")
+ bool, Field(description="Whether this Dag's schedule supports backfilling.", title="Is Backfillable")
]
file_token: Annotated[str, Field(description="Return file token.", title="File Token")]
class DAGRunPatchBody(BaseModel):
"""
- DAG Run Serializer for PATCH requests.
+ Dag Run Serializer for PATCH requests.
"""
model_config = ConfigDict(
@@ -1500,7 +1500,7 @@ class DAGRunPatchBody(BaseModel):
class DAGRunResponse(BaseModel):
"""
- DAG Run serializer for responses.
+ Dag Run serializer for responses.
"""
dag_run_id: Annotated[str, Field(title="Dag Run Id")]
@@ -1528,7 +1528,7 @@ class DAGRunResponse(BaseModel):
class DAGRunsBatchBody(BaseModel):
"""
- List DAG Runs body for batch endpoint.
+ List Dag Runs body for batch endpoint.
"""
model_config = ConfigDict(
@@ -1564,7 +1564,7 @@ class DAGRunsBatchBody(BaseModel):
class DAGVersionCollectionResponse(BaseModel):
"""
- DAG Version Collection serializer for responses.
+ Dag Version Collection serializer for responses.
"""
dag_versions: Annotated[list[DagVersionResponse], Field(title="Dag Versions")]
@@ -1573,7 +1573,7 @@ class DAGVersionCollectionResponse(BaseModel):
class DAGWarningResponse(BaseModel):
"""
- DAG Warning serializer for responses.
+ Dag Warning serializer for responses.
"""
dag_id: Annotated[str, Field(title="Dag Id")]
@@ -1585,7 +1585,7 @@ class DAGWarningResponse(BaseModel):
class DagStatsResponse(BaseModel):
"""
- DAG Stats serializer for responses.
+ Dag Stats serializer for responses.
"""
dag_id: Annotated[str, Field(title="Dag Id")]
@@ -1969,7 +1969,7 @@ class ClearTaskInstanceCollectionResponse(BaseModel):
class DAGCollectionResponse(BaseModel):
"""
- DAG Collection serializer for responses.
+ Dag Collection serializer for responses.
"""
dags: Annotated[list[DAGResponse], Field(title="Dags")]
@@ -1978,7 +1978,7 @@ class DAGCollectionResponse(BaseModel):
class DAGRunCollectionResponse(BaseModel):
"""
- DAG Run collection response supporting both offset and cursor pagination.
+ Dag Run collection response supporting both offset and cursor pagination.
A single flat model is used instead of a discriminated union
(``Annotated[Offset | Cursor, Field(discriminator=...)]``) because
@@ -2014,7 +2014,7 @@ class DAGRunCollectionResponse(BaseModel):
class DAGWarningCollectionResponse(BaseModel):
"""
- DAG warning collection serializer for responses.
+ Dag warning collection serializer for responses.
"""
dag_warnings: Annotated[list[DAGWarningResponse], Field(title="Dag Warnings")]
@@ -2023,7 +2023,7 @@ class DAGWarningCollectionResponse(BaseModel):
class DagStatsCollectionResponse(BaseModel):
"""
- DAG Stats Collection serializer for responses.
+ Dag Stats Collection serializer for responses.
"""
dags: Annotated[list[DagStatsResponse], Field(title="Dags")]
diff --git a/airflow-ctl/src/airflowctl/api/operations.py b/airflow-ctl/src/airflowctl/api/operations.py
index 7718c1c5649..f52ba055c1c 100644
--- a/airflow-ctl/src/airflowctl/api/operations.py
+++ b/airflow-ctl/src/airflowctl/api/operations.py
@@ -509,7 +509,7 @@ class DagsOperations(BaseOperations):
"""Dags operations."""
def get(self, dag_id: str) -> DAGResponse | ServerResponseError:
- """Get a DAG."""
+ """Get a Dag."""
try:
self.response = self.client.get(f"dags/{dag_id}")
return DAGResponse.model_validate_json(self.response.content)
diff --git a/airflow-ctl/src/airflowctl/ctl/cli_config.py b/airflow-ctl/src/airflowctl/ctl/cli_config.py
index c540b939fbf..aa96304f501 100755
--- a/airflow-ctl/src/airflowctl/ctl/cli_config.py
+++ b/airflow-ctl/src/airflowctl/ctl/cli_config.py
@@ -265,7 +265,7 @@ ARG_AUTH_PASSWORD = Arg(
ARG_DAG_ID = Arg(
flags=("dag_id",),
type=str,
- help="The DAG ID of the DAG to pause or unpause",
+ help="The Dag ID of the Dag to pause or unpause",
)
ARG_ACTION_ON_EXISTING_KEY = Arg(
diff --git a/airflow-ctl/src/airflowctl/ctl/commands/config_command.py b/airflow-ctl/src/airflowctl/ctl/commands/config_command.py
index b4cb9725ca8..20147484d94 100644
--- a/airflow-ctl/src/airflowctl/ctl/commands/config_command.py
+++ b/airflow-ctl/src/airflowctl/ctl/commands/config_command.py
@@ -540,9 +540,9 @@ CONFIGS_CHANGES = [
was_removed=False,
new_default="False",
suggestion="In Airflow 3.0 the default value for `catchup_by_default` is set to `False`. "
- "This means that DAGs without explicit definition of the `catchup` parameter will not "
+ "This means that Dags without explicit definition of the `catchup` parameter will not "
"catchup by default. "
- "If your DAGs rely on catchup behavior, not explicitly defined in the DAG definition, "
+ "If your Dags rely on catchup behavior, not explicitly defined in the Dag definition, "
"set this configuration parameter to `True` in the `scheduler` section of your `airflow.cfg` "
"to enable the behavior from Airflow 2.x.",
breaking=True,
diff --git a/airflow-ctl/src/airflowctl/ctl/commands/dag_command.py b/airflow-ctl/src/airflowctl/ctl/commands/dag_command.py
index 9b43be47eb2..33b3d7c95fe 100644
--- a/airflow-ctl/src/airflowctl/ctl/commands/dag_command.py
+++ b/airflow-ctl/src/airflowctl/ctl/commands/dag_command.py
@@ -33,7 +33,7 @@ def update_dag_state(
api_client,
output: str,
):
- """Update DAG state (pause/unpause)."""
+ """Update Dag state (pause/unpause)."""
try:
response = api_client.dags.update(
dag_id=dag_id, dag_body=DAGPatchBody(is_paused=operation == "pause")
@@ -54,7 +54,7 @@ def update_dag_state(
@provide_api_client(kind=ClientKind.CLI)
def pause(args, api_client=NEW_API_CLIENT) -> None:
- """Pause a DAG."""
+ """Pause a Dag."""
return update_dag_state(
dag_id=args.dag_id,
operation="pause",
@@ -65,7 +65,7 @@ def pause(args, api_client=NEW_API_CLIENT) -> None:
@provide_api_client(kind=ClientKind.CLI)
def unpause(args, api_client=NEW_API_CLIENT) -> None:
- """Unpause a DAG."""
+ """Unpause a Dag."""
return update_dag_state(
dag_id=args.dag_id,
operation="unpause",
diff --git a/airflow-ctl/src/airflowctl/ctl/help_texts.yaml b/airflow-ctl/src/airflowctl/ctl/help_texts.yaml
index 3dac52be0bc..eb566a96b1f 100644
--- a/airflow-ctl/src/airflowctl/ctl/help_texts.yaml
+++ b/airflow-ctl/src/airflowctl/ctl/help_texts.yaml
@@ -23,17 +23,17 @@ assets:
create-event: "Create an event for a given asset"
materialize: "Trigger materialization of an asset by its ID"
get-queued-events: "List queued events for a given asset"
- get-dag-queued-events: "List queued asset events for a given DAG"
- get-dag-queued-event: "Retrieve a specific queued asset event for a given DAG and asset"
+ get-dag-queued-events: "List queued asset events for a given Dag"
+ get-dag-queued-event: "Retrieve a specific queued asset event for a given Dag and asset"
delete-queued-events: "Delete all queued events for a given asset"
- delete-dag-queued-events: "Delete all queued asset events for a given DAG"
- delete-queued-event: "Delete a specific queued asset event for a given DAG and asset"
+ delete-dag-queued-events: "Delete all queued asset events for a given Dag"
+ delete-queued-event: "Delete a specific queued asset event for a given Dag and asset"
backfill:
- create: "Create a backfill job for a given DAG ID and date range"
+ create: "Create a backfill job for a given Dag ID and date range"
create-dry-run: "Preview a backfill job without executing it"
get: "Retrieve details of a backfill job by its ID"
- list: "List all backfill jobs for a given DAG"
+ list: "List all backfill jobs for a given Dag"
pause: "Pause an active backfill job"
unpause: "Resume a paused backfill job"
cancel: "Cancel a backfill job"
@@ -52,23 +52,23 @@ connections:
test: "Test connectivity for a given connection"
dags:
- get: "Retrieve a DAG by its ID"
- get-details: "Retrieve detailed information for a DAG"
- get-tags: "List all tags used across DAGs"
- list: "List all DAGs"
- update: "Update properties of a DAG"
- delete: "Delete a DAG by its ID"
- get-import-error: "Retrieve a DAG import error by its ID"
- list-import-errors: "List all DAG import errors"
- get-stats: "Retrieve run statistics for one or more DAGs"
- get-version: "Retrieve a specific version of a DAG"
- list-version: "List all versions of a DAG"
- list-warning: "List all DAG warnings"
- trigger: "Trigger a new DAG run"
+ get: "Retrieve a Dag by its ID"
+ get-details: "Retrieve detailed information for a Dag"
+ get-tags: "List all tags used across Dags"
+ list: "List all Dags"
+ update: "Update properties of a Dag"
+ delete: "Delete a Dag by its ID"
+ get-import-error: "Retrieve a Dag import error by its ID"
+ list-import-errors: "List all Dag import errors"
+ get-stats: "Retrieve run statistics for one or more Dags"
+ get-version: "Retrieve a specific version of a Dag"
+ list-version: "List all versions of a Dag"
+ list-warning: "List all Dag warnings"
+ trigger: "Trigger a new Dag run"
dagrun:
- get: "Retrieve a DAG run by DAG ID and run ID"
- list: "List DAG runs, optionally filtered by state and date range"
+ get: "Retrieve a Dag run by Dag ID and run ID"
+ list: "List Dag runs, optionally filtered by state and date range"
jobs:
list: "List scheduler, triggerer, and other Airflow jobs"