fix(specs): ingestion docker task input (generated)

algolia/api-clients-automation#3488

Co-authored-by: algolia-bot <[email protected]>
Co-authored-by: Clément Vannicatte <[email protected]>

Author: algolia-bot

algoliasearch/ingestion/client.py

@@ -4008,7 +4008,7 @@ async def trigger_docker_source_discover(
             )
         ).deserialize(SourceWatchResponse)
 
-    async def try_transformations_with_http_info(
+    async def try_transformation_with_http_info(
         self,
         transformation_try: TransformationTry,
         request_options: Optional[Union[dict, RequestOptions]] = None,
@@ -4029,7 +4029,7 @@ async def try_transformations_with_http_info(
 
         if transformation_try is None:
             raise ValueError(
-                "Parameter `transformation_try` is required when calling `try_transformations`."
+                "Parameter `transformation_try` is required when calling `try_transformation`."
             )
 
         _data = {}
@@ -4046,7 +4046,7 @@ async def try_transformations_with_http_info(
             use_read_transporter=False,
         )
 
-    async def try_transformations(
+    async def try_transformation(
         self,
         transformation_try: TransformationTry,
         request_options: Optional[Union[dict, RequestOptions]] = None,
@@ -4065,7 +4065,7 @@ async def try_transformations(
         :return: Returns the deserialized response in a 'TransformationTryResponse' result object.
         """
         return (
-            await self.try_transformations_with_http_info(
+            await self.try_transformation_with_http_info(
                 transformation_try, request_options
             )
         ).deserialize(TransformationTryResponse)

algoliasearch/ingestion/models/docker_streams.py

@@ -0,0 +1,78 @@
+# coding: utf-8
+
+"""
+Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
+"""
+
+from __future__ import annotations
+
+from json import loads
+from typing import Any, Dict, List, Optional, Self
+
+from pydantic import BaseModel, ConfigDict, Field, StrictStr
+
+from algoliasearch.ingestion.models.docker_streams_sync_mode import (
+    DockerStreamsSyncMode,
+)
+
+
+class DockerStreams(BaseModel):
+    """
+    DockerStreams
+    """
+
+    name: StrictStr = Field(
+        description="The name of the stream to fetch the data from (e.g. table name)."
+    )
+    properties: Optional[List[StrictStr]] = Field(
+        default=None,
+        description="The properties of the stream to select (e.g. column).",
+    )
+    sync_mode: DockerStreamsSyncMode = Field(alias="syncMode")
+
+    model_config = ConfigDict(
+        use_enum_values=True, populate_by_name=True, validate_assignment=True
+    )
+
+    def to_json(self) -> str:
+        return self.model_dump_json(by_alias=True, exclude_unset=True)
+
+    @classmethod
+    def from_json(cls, json_str: str) -> Self:
+        """Create an instance of DockerStreams from a JSON string"""
+        return cls.from_dict(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.
+        """
+        _dict = self.model_dump(
+            by_alias=True,
+            exclude={},
+            exclude_none=True,
+        )
+        return _dict
+
+    @classmethod
+    def from_dict(cls, obj: Dict) -> Self:
+        """Create an instance of DockerStreams from a dict"""
+        if obj is None:
+            return None
+
+        if not isinstance(obj, dict):
+            return cls.model_validate(obj)
+
+        _obj = cls.model_validate(
+            {
+                "name": obj.get("name"),
+                "properties": obj.get("properties"),
+                "syncMode": obj.get("syncMode"),
+            }
+        )
+        return _obj

algoliasearch/ingestion/models/docker_streams_input.py

@@ -7,17 +7,19 @@
 from __future__ import annotations
 
 from json import loads
-from typing import Any, Dict, Self
+from typing import Any, Dict, List, Self
 
 from pydantic import BaseModel, ConfigDict
 
+from algoliasearch.ingestion.models.docker_streams import DockerStreams
+
 
 class DockerStreamsInput(BaseModel):
     """
     The selected streams of a singer or airbyte connector.
     """
 
-    streams: Dict[str, Any]
+    streams: List[DockerStreams]
 
     model_config = ConfigDict(
         use_enum_values=True, populate_by_name=True, validate_assignment=True
@@ -46,6 +48,12 @@ def to_dict(self) -> Dict[str, Any]:
             exclude={},
             exclude_none=True,
         )
+        _items = []
+        if self.streams:
+            for _item in self.streams:
+                if _item:
+                    _items.append(_item.to_dict())
+            _dict["streams"] = _items
         return _dict
 
     @classmethod
@@ -57,5 +65,13 @@ def from_dict(cls, obj: Dict) -> Self:
         if not isinstance(obj, dict):
             return cls.model_validate(obj)
 
-        _obj = cls.model_validate({"streams": obj.get("streams")})
+        _obj = cls.model_validate(
+            {
+                "streams": (
+                    [DockerStreams.from_dict(_item) for _item in obj.get("streams")]
+                    if obj.get("streams") is not None
+                    else None
+                )
+            }
+        )
         return _obj

algoliasearch/ingestion/models/docker_streams_sync_mode.py

@@ -0,0 +1,28 @@
+# coding: utf-8
+
+"""
+Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
+"""
+
+from __future__ import annotations
+
+from enum import Enum
+from json import loads
+from typing import Self
+
+
+class DockerStreamsSyncMode(str, Enum):
+    """
+    The strategy to use to fetch the data.
+    """
+
+    """
+    allowed enum values
+    """
+    INCREMENTAL = "incremental"
+    FULLTABLE = "fullTable"
+
+    @classmethod
+    def from_json(cls, json_str: str) -> Self:
+        """Create an instance of DockerStreamsSyncMode from a JSON string"""
+        return cls(loads(json_str))