| # 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, StrictInt |
| from typing import Any, ClassVar, Dict, List |
| from airflow_client.client.models.x_com_response import XComResponse |
| from typing import Optional, Set |
| from typing_extensions import Self |
| |
| class XComCollectionResponse(BaseModel): |
| """ |
| XCom Collection serializer for responses. |
| """ # noqa: E501 |
| total_entries: StrictInt |
| xcom_entries: List[XComResponse] |
| __properties: ClassVar[List[str]] = ["total_entries", "xcom_entries"] |
| |
| 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 XComCollectionResponse 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 xcom_entries (list) |
| _items = [] |
| if self.xcom_entries: |
| for _item_xcom_entries in self.xcom_entries: |
| if _item_xcom_entries: |
| _items.append(_item_xcom_entries.to_dict()) |
| _dict['xcom_entries'] = _items |
| return _dict |
| |
| @classmethod |
| def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: |
| """Create an instance of XComCollectionResponse from a dict""" |
| if obj is None: |
| return None |
| |
| if not isinstance(obj, dict): |
| return cls.model_validate(obj) |
| |
| _obj = cls.model_validate({ |
| "total_entries": obj.get("total_entries"), |
| "xcom_entries": [XComResponse.from_dict(_item) for _item in obj["xcom_entries"]] if obj.get("xcom_entries") is not None else None |
| }) |
| return _obj |
| |
| |