Body
Make list operations to return all results. It is returning the first iteration of the list endpoint because the default limit is 100 for the API endpoints.
Limit:
|
def depends(cls, limit: NonNegativeInt = 100) -> LimitFilter: |
Code:
|
# TODO: Get all with limit and offset to overcome default 100 limit for all list operations |
|
def list(self) -> AssetCollectionResponse | ServerResponseError: |
|
"""List all assets from the API server.""" |
|
try: |
|
self.response = self.client.get("assets") |
|
return AssetCollectionResponse.model_validate_json(self.response.content) |
|
except ServerResponseError as e: |
|
raise e |
|
|
|
def list_by_alias(self) -> AssetAliasCollectionResponse | ServerResponseError: |
|
"""List all assets by alias from the API server.""" |
|
try: |
|
self.response = self.client.get("/assets/aliases") |
|
return AssetAliasCollectionResponse.model_validate_json(self.response.content) |
|
except ServerResponseError as e: |
|
raise e |
Committer
Body
Make list operations to return all results. It is returning the first iteration of the list endpoint because the default limit is 100 for the API endpoints.
Limit:
airflow/airflow-core/src/airflow/api_fastapi/common/parameters.py
Line 97 in b46275b
Code:
airflow/airflow-ctl/src/airflowctl/api/operations.py
Line 135 in b46275b
airflow/airflow-ctl/src/airflowctl/api/operations.py
Lines 155 to 169 in b46275b
Committer