feat(specs): add subscriptionAction to ingestion specs (generated)

algolia/api-clients-automation#4587

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

Author: algolia-bot

algoliasearch/ingestion/models/task.py

@@ -34,6 +34,7 @@
     "enabled": "enabled",
     "failure_threshold": "failureThreshold",
     "action": "action",
+    "subscription_action": "subscriptionAction",
     "cursor": "cursor",
     "notifications": "notifications",
     "policies": "policies",
@@ -69,6 +70,7 @@ class Task(BaseModel):
     failure_threshold: Optional[int] = None
     """ Maximum accepted percentage of failures for a task run to finish successfully. """
     action: Optional[ActionType] = None
+    subscription_action: Optional[ActionType] = None
     cursor: Optional[str] = None
     """ Date of the last cursor in RFC 3339 format. """
     notifications: Optional[Notifications] = None
@@ -117,6 +119,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
             TaskInput.from_dict(obj["input"]) if obj.get("input") is not None else None
         )
         obj["action"] = obj.get("action")
+        obj["subscriptionAction"] = obj.get("subscriptionAction")
         obj["notifications"] = (
             Notifications.from_dict(obj["notifications"])
             if obj.get("notifications") is not None

algoliasearch/ingestion/models/task_create.py

@@ -27,6 +27,7 @@
     "source_id": "sourceID",
     "destination_id": "destinationID",
     "action": "action",
+    "subscription_action": "subscriptionAction",
     "cron": "cron",
     "enabled": "enabled",
     "failure_threshold": "failureThreshold",
@@ -51,6 +52,7 @@ class TaskCreate(BaseModel):
     destination_id: str
     """ Universally unique identifier (UUID) of a destination resource. """
     action: ActionType
+    subscription_action: Optional[ActionType] = None
     cron: Optional[str] = None
     """ Cron expression for the task's schedule. """
     enabled: Optional[bool] = None
@@ -99,6 +101,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
             return cls.model_validate(obj)
 
         obj["action"] = obj.get("action")
+        obj["subscriptionAction"] = obj.get("subscriptionAction")
         obj["input"] = (
             TaskInput.from_dict(obj["input"]) if obj.get("input") is not None else None
         )

algoliasearch/ingestion/models/task_update.py

@@ -18,6 +18,7 @@
     from typing_extensions import Self
 
 
+from algoliasearch.ingestion.models.action_type import ActionType
 from algoliasearch.ingestion.models.notifications import Notifications
 from algoliasearch.ingestion.models.policies import Policies
 from algoliasearch.ingestion.models.task_input import TaskInput
@@ -27,6 +28,7 @@
     "cron": "cron",
     "input": "input",
     "enabled": "enabled",
+    "subscription_action": "subscriptionAction",
     "failure_threshold": "failureThreshold",
     "notifications": "notifications",
     "policies": "policies",
@@ -49,6 +51,7 @@ class TaskUpdate(BaseModel):
     input: Optional[TaskInput] = None
     enabled: Optional[bool] = None
     """ Whether the task is enabled. """
+    subscription_action: Optional[ActionType] = None
     failure_threshold: Optional[int] = None
     """ Maximum accepted percentage of failures for a task run to finish successfully. """
     notifications: Optional[Notifications] = None
@@ -92,6 +95,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         obj["input"] = (
             TaskInput.from_dict(obj["input"]) if obj.get("input") is not None else None
         )
+        obj["subscriptionAction"] = obj.get("subscriptionAction")
         obj["notifications"] = (
             Notifications.from_dict(obj["notifications"])
             if obj.get("notifications") is not None