| # coding: utf-8 |
| |
| """ |
| Airflow API |
| |
| Airflow API. All endpoints located under ``/api/v2`` can be used safely, are stable and backward compatible. Endpoints located under ``/ui`` are dedicated to the UI and are subject to breaking change depending on the need of the frontend. Users should not rely on those but use the public ones instead. |
| |
| The version of the OpenAPI document: 2 |
| Generated by OpenAPI Generator (https://openapi-generator.tech) |
| |
| Do not edit the class manually. |
| """ # noqa: E501 |
| |
| |
| from __future__ import annotations |
| import pprint |
| import re # noqa: F401 |
| import json |
| |
| from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator |
| from typing import Any, ClassVar, Dict, List, Optional |
| from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence |
| from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner |
| from typing import Optional, Set |
| from typing_extensions import Self |
| |
| class BulkDeleteActionPoolBody(BaseModel): |
| """ |
| BulkDeleteActionPoolBody |
| """ # noqa: E501 |
| action: StrictStr = Field(description="The action to be performed on the entities.") |
| action_on_non_existence: Optional[BulkActionNotOnExistence] = None |
| entities: List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") |
| __properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"] |
| |
| @field_validator('action') |
| def action_validate_enum(cls, value): |
| """Validates the enum""" |
| if value not in set(['delete']): |
| raise ValueError("must be one of enum values ('delete')") |
| return value |
| |
| model_config = ConfigDict( |
| populate_by_name=True, |
| validate_assignment=True, |
| protected_namespaces=(), |
| ) |
| |
| |
| def to_str(self) -> str: |
| """Returns the string representation of the model using alias""" |
| return pprint.pformat(self.model_dump(by_alias=True)) |
| |
| def to_json(self) -> str: |
| """Returns the JSON representation of the model using alias""" |
| # TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead |
| return json.dumps(self.to_dict()) |
| |
| @classmethod |
| def from_json(cls, json_str: str) -> Optional[Self]: |
| """Create an instance of BulkDeleteActionPoolBody from a JSON string""" |
| return cls.from_dict(json.loads(json_str)) |
| |
| def to_dict(self) -> Dict[str, Any]: |
| """Return the dictionary representation of the model using alias. |
| |
| This has the following differences from calling pydantic's |
| `self.model_dump(by_alias=True)`: |
| |
| * `None` is only added to the output dict for nullable fields that |
| were set at model initialization. Other fields with value `None` |
| are ignored. |
| """ |
| excluded_fields: Set[str] = set([ |
| ]) |
| |
| _dict = self.model_dump( |
| by_alias=True, |
| exclude=excluded_fields, |
| exclude_none=True, |
| ) |
| # override the default output from pydantic by calling `to_dict()` of each item in entities (list) |
| _items = [] |
| if self.entities: |
| for _item_entities in self.entities: |
| if _item_entities: |
| _items.append(_item_entities.to_dict()) |
| _dict['entities'] = _items |
| return _dict |
| |
| @classmethod |
| def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: |
| """Create an instance of BulkDeleteActionPoolBody from a dict""" |
| if obj is None: |
| return None |
| |
| if not isinstance(obj, dict): |
| return cls.model_validate(obj) |
| |
| _obj = cls.model_validate({ |
| "action": obj.get("action"), |
| "action_on_non_existence": obj.get("action_on_non_existence"), |
| "entities": [BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None |
| }) |
| return _obj |
| |
| |