diff --git a/airflow-ctl/docs/images/command_hashes.txt b/airflow-ctl/docs/images/command_hashes.txt index 53c93e7546d1e..3a0962cc4eee6 100644 --- a/airflow-ctl/docs/images/command_hashes.txt +++ b/airflow-ctl/docs/images/command_hashes.txt @@ -1,5 +1,5 @@ main:27a22c00dcf32e7a1a4f06672dc8e3c8 -assets:70619a2d92bda80930cde2aefcd8e1cd +assets:6419e20452692f577c4c6f570b74be0c auth:d79e9c7d00c432bdbcbc2a86e2e32053 backfill:74c8737b0a62a86ed3605fa9e6165874 config:a3d936cb15fe3b547bf6c82cf93d923f diff --git a/airflow-ctl/docs/images/output_assets.svg b/airflow-ctl/docs/images/output_assets.svg index b76118dc52aeb..12214b4fd7441 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-3582101150-matrix { + .terminal-2929493646-matrix { font-family: Fira Code, monospace; font-size: 20px; line-height: 24.4px; font-variant-east-asian: full-width; } - .terminal-3582101150-title { + .terminal-2929493646-title { font-size: 18px; font-weight: bold; font-family: arial; } - .terminal-3582101150-r1 { fill: #ff8700 } -.terminal-3582101150-r2 { fill: #c5c8c6 } -.terminal-3582101150-r3 { fill: #808080 } -.terminal-3582101150-r4 { fill: #68a0b3 } + .terminal-2929493646-r1 { fill: #ff8700 } +.terminal-2929493646-r2 { fill: #c5c8c6 } +.terminal-2929493646-r3 { fill: #808080 } +.terminal-2929493646-r4 { fill: #68a0b3 } - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + @@ -132,37 +132,37 @@ - + - - Usage:airflowctl assets [-hCOMMAND... - -Perform Assets operations - -Positional Arguments: -COMMAND -create-eventCreate an event 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-queued-events -Delete all queued events for a given asset -getRetrieve an asset by its ID -get-by-aliasRetrieve an asset by its alias -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-queued-eventsList queued events for a given asset -listList all assets -list-by-aliasList all asset aliases -materializeTrigger materialization of an asset by its ID - -Options: --h--helpshow this help message and exit + + Usage:airflowctl assets [-hCOMMAND... + +Perform Assets operations + +Positional Arguments: +COMMAND +create-eventCreate an event 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-queued-events +Delete all queued events for a given asset +getRetrieve an asset by its ID +get-by-aliasRetrieve an asset by its alias +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-queued-eventsList queued events for a given asset +listList all assets +list-aliasesList all asset aliases +materializeTrigger materialization of an asset by its ID + +Options: +-h--helpshow this help message and exit diff --git a/airflow-ctl/src/airflowctl/api/operations.py b/airflow-ctl/src/airflowctl/api/operations.py index e250b66e127dd..d1782afaaaafc 100644 --- a/airflow-ctl/src/airflowctl/api/operations.py +++ b/airflow-ctl/src/airflowctl/api/operations.py @@ -269,8 +269,8 @@ def list(self) -> AssetCollectionResponse | ServerResponseError: """List all assets from the API server.""" return super().execute_list(path="assets", data_model=AssetCollectionResponse) - def list_by_alias(self) -> AssetAliasCollectionResponse | ServerResponseError: - """List all assets by alias from the API server.""" + def list_aliases(self) -> AssetAliasCollectionResponse | ServerResponseError: + """List all assets aliases from the API server.""" return super().execute_list(path="/assets/aliases", data_model=AssetAliasCollectionResponse) def create_event( diff --git a/airflow-ctl/src/airflowctl/ctl/help_texts.yaml b/airflow-ctl/src/airflowctl/ctl/help_texts.yaml index eb566a96b1fb8..2e3266fc20561 100644 --- a/airflow-ctl/src/airflowctl/ctl/help_texts.yaml +++ b/airflow-ctl/src/airflowctl/ctl/help_texts.yaml @@ -19,7 +19,7 @@ assets: get: "Retrieve an asset by its ID" get-by-alias: "Retrieve an asset by its alias" list: "List all assets" - list-by-alias: "List all asset aliases" + list-aliases: "List all asset aliases" 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" diff --git a/airflow-ctl/tests/airflow_ctl/api/test_operations.py b/airflow-ctl/tests/airflow_ctl/api/test_operations.py index 52faecee73ea0..74bc68ed05e65 100644 --- a/airflow-ctl/tests/airflow_ctl/api/test_operations.py +++ b/airflow-ctl/tests/airflow_ctl/api/test_operations.py @@ -368,7 +368,7 @@ def handle_request(request: httpx.Request) -> httpx.Response: response = client.assets.list() assert response == assets_collection_response - def test_list_by_alias(self): + def test_list_aliases(self): assets_collection_response = AssetAliasCollectionResponse( asset_aliases=[self.asset_alias_response], total_entries=1, @@ -379,7 +379,7 @@ def handle_request(request: httpx.Request) -> httpx.Response: return httpx.Response(200, json=json.loads(assets_collection_response.model_dump_json())) client = make_api_client(transport=httpx.MockTransport(handle_request)) - response = client.assets.list_by_alias() + response = client.assets.list_aliases() assert response == assets_collection_response def test_create_event(self): diff --git a/scripts/ci/prek/check_airflowctl_command_coverage.py b/scripts/ci/prek/check_airflowctl_command_coverage.py index 6ee54d369bb7d..44ef0c34bb8e3 100755 --- a/scripts/ci/prek/check_airflowctl_command_coverage.py +++ b/scripts/ci/prek/check_airflowctl_command_coverage.py @@ -57,7 +57,7 @@ "assets get-dag-queued-event", "assets get-dag-queued-events", "assets get-queued-events", - "assets list-by-alias", + "assets list-aliases", "assets materialize", "backfill cancel", "backfill create",