feat(api): add schedule resume

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 64
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp/agentex-sdk-ebf2fa494f7a5d48ae4f9634d6cf0b963f6df38a34d8971af032a9b26549fe55.yml
+configured_endpoints: 65
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp/agentex-sdk-9c05120db888b0cb0d18336b5ae10d0abb2ea0b3d553907c47ffb21b94f84297.yml
 openapi_spec_hash: cdea9763ef58e87c5486cb9e026b6fc9
-config_hash: 3b6725755e95a0dca3a1fee0a778c6ba
+config_hash: 7ca6c24d238deb860f1ddeb5913ca235

api.md

@@ -71,6 +71,7 @@ from agentex.types.agents import (
     ScheduleRetrieveResponse,
     ScheduleListResponse,
     SchedulePauseResponse,
+    ScheduleResumeResponse,
     ScheduleTriggerResponse,
 )
 ```
@@ -82,6 +83,7 @@ Methods:
 - <code title="get /agents/{agent_id}/schedules">client.agents.schedules.<a href="./src/agentex/resources/agents/schedules.py">list</a>(agent_id, \*\*<a href="src/agentex/types/agents/schedule_list_params.py">params</a>) -> <a href="./src/agentex/types/agents/schedule_list_response.py">ScheduleListResponse</a></code>
 - <code title="delete /agents/{agent_id}/schedules/name/{name}">client.agents.schedules.<a href="./src/agentex/resources/agents/schedules.py">delete</a>(name, \*, agent_id) -> <a href="./src/agentex/types/shared/delete_response.py">DeleteResponse</a></code>
 - <code title="post /agents/{agent_id}/schedules/name/{name}/pause">client.agents.schedules.<a href="./src/agentex/resources/agents/schedules.py">pause</a>(name, \*, agent_id, \*\*<a href="src/agentex/types/agents/schedule_pause_params.py">params</a>) -> <a href="./src/agentex/types/agents/schedule_pause_response.py">SchedulePauseResponse</a></code>
+- <code title="post /agents/{agent_id}/schedules/name/{name}/resume">client.agents.schedules.<a href="./src/agentex/resources/agents/schedules.py">resume</a>(name, \*, agent_id, \*\*<a href="src/agentex/types/agents/schedule_resume_params.py">params</a>) -> <a href="./src/agentex/types/agents/schedule_resume_response.py">ScheduleResumeResponse</a></code>
 - <code title="post /agents/{agent_id}/schedules/name/{name}/trigger">client.agents.schedules.<a href="./src/agentex/resources/agents/schedules.py">trigger</a>(name, \*, agent_id) -> <a href="./src/agentex/types/agents/schedule_trigger_response.py">ScheduleTriggerResponse</a></code>
 
 # Tasks

src/agentex/resources/agents/schedules.py

@@ -18,11 +18,12 @@
     async_to_streamed_response_wrapper,
 )
 from ..._base_client import make_request_options
-from ...types.agents import schedule_list_params, schedule_pause_params, schedule_create_params
+from ...types.agents import schedule_list_params, schedule_pause_params, schedule_create_params, schedule_resume_params
 from ...types.shared.delete_response import DeleteResponse
 from ...types.agents.schedule_list_response import ScheduleListResponse
 from ...types.agents.schedule_pause_response import SchedulePauseResponse
 from ...types.agents.schedule_create_response import ScheduleCreateResponse
+from ...types.agents.schedule_resume_response import ScheduleResumeResponse
 from ...types.agents.schedule_trigger_response import ScheduleTriggerResponse
 from ...types.agents.schedule_retrieve_response import ScheduleRetrieveResponse
 
@@ -282,6 +283,46 @@ def pause(
             cast_to=SchedulePauseResponse,
         )
 
+    def resume(
+        self,
+        name: str,
+        *,
+        agent_id: str,
+        note: Optional[str] | Omit = omit,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> ScheduleResumeResponse:
+        """
+        Resume a paused run schedule by its active name.
+
+        Args:
+          note: Optional note explaining the resume.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not agent_id:
+            raise ValueError(f"Expected a non-empty value for `agent_id` but received {agent_id!r}")
+        if not name:
+            raise ValueError(f"Expected a non-empty value for `name` but received {name!r}")
+        return self._post(
+            path_template("/agents/{agent_id}/schedules/name/{name}/resume", agent_id=agent_id, name=name),
+            body=maybe_transform({"note": note}, schedule_resume_params.ScheduleResumeParams),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=ScheduleResumeResponse,
+        )
+
     def trigger(
         self,
         name: str,
@@ -572,6 +613,46 @@ async def pause(
             cast_to=SchedulePauseResponse,
         )
 
+    async def resume(
+        self,
+        name: str,
+        *,
+        agent_id: str,
+        note: Optional[str] | Omit = omit,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> ScheduleResumeResponse:
+        """
+        Resume a paused run schedule by its active name.
+
+        Args:
+          note: Optional note explaining the resume.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not agent_id:
+            raise ValueError(f"Expected a non-empty value for `agent_id` but received {agent_id!r}")
+        if not name:
+            raise ValueError(f"Expected a non-empty value for `name` but received {name!r}")
+        return await self._post(
+            path_template("/agents/{agent_id}/schedules/name/{name}/resume", agent_id=agent_id, name=name),
+            body=await async_maybe_transform({"note": note}, schedule_resume_params.ScheduleResumeParams),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=ScheduleResumeResponse,
+        )
+
     async def trigger(
         self,
         name: str,
@@ -628,6 +709,9 @@ def __init__(self, schedules: SchedulesResource) -> None:
         self.pause = to_raw_response_wrapper(
             schedules.pause,
         )
+        self.resume = to_raw_response_wrapper(
+            schedules.resume,
+        )
         self.trigger = to_raw_response_wrapper(
             schedules.trigger,
         )
@@ -652,6 +736,9 @@ def __init__(self, schedules: AsyncSchedulesResource) -> None:
         self.pause = async_to_raw_response_wrapper(
             schedules.pause,
         )
+        self.resume = async_to_raw_response_wrapper(
+            schedules.resume,
+        )
         self.trigger = async_to_raw_response_wrapper(
             schedules.trigger,
         )
@@ -676,6 +763,9 @@ def __init__(self, schedules: SchedulesResource) -> None:
         self.pause = to_streamed_response_wrapper(
             schedules.pause,
         )
+        self.resume = to_streamed_response_wrapper(
+            schedules.resume,
+        )
         self.trigger = to_streamed_response_wrapper(
             schedules.trigger,
         )
@@ -700,6 +790,9 @@ def __init__(self, schedules: AsyncSchedulesResource) -> None:
         self.pause = async_to_streamed_response_wrapper(
             schedules.pause,
         )
+        self.resume = async_to_streamed_response_wrapper(
+            schedules.resume,
+        )
         self.trigger = async_to_streamed_response_wrapper(
             schedules.trigger,
         )

src/agentex/types/agents/__init__.py

@@ -7,10 +7,12 @@
 from .deployment_list_params import DeploymentListParams as DeploymentListParams
 from .schedule_create_params import ScheduleCreateParams as ScheduleCreateParams
 from .schedule_list_response import ScheduleListResponse as ScheduleListResponse
+from .schedule_resume_params import ScheduleResumeParams as ScheduleResumeParams
 from .schedule_pause_response import SchedulePauseResponse as SchedulePauseResponse
 from .deployment_create_params import DeploymentCreateParams as DeploymentCreateParams
 from .deployment_list_response import DeploymentListResponse as DeploymentListResponse
 from .schedule_create_response import ScheduleCreateResponse as ScheduleCreateResponse
+from .schedule_resume_response import ScheduleResumeResponse as ScheduleResumeResponse
 from .schedule_trigger_response import ScheduleTriggerResponse as ScheduleTriggerResponse
 from .deployment_create_response import DeploymentCreateResponse as DeploymentCreateResponse
 from .schedule_retrieve_response import ScheduleRetrieveResponse as ScheduleRetrieveResponse

src/agentex/types/agents/schedule_resume_params.py

@@ -0,0 +1,15 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from __future__ import annotations
+
+from typing import Optional
+from typing_extensions import Required, TypedDict
+
+__all__ = ["ScheduleResumeParams"]
+
+
+class ScheduleResumeParams(TypedDict, total=False):
+    agent_id: Required[str]
+
+    note: Optional[str]
+    """Optional note explaining the resume."""

src/agentex/types/agents/schedule_resume_response.py

@@ -0,0 +1,114 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Dict, List, Optional
+from datetime import datetime
+from typing_extensions import Literal
+
+from ..._models import BaseModel
+from ..message_author import MessageAuthor
+
+__all__ = ["ScheduleResumeResponse", "InitialInput", "CreatorPrincipal"]
+
+
+class InitialInput(BaseModel):
+    """The initial input."""
+
+    content: str
+    """The initial prompt delivered to the task."""
+
+    author: Optional[MessageAuthor] = None
+    """The author attributed to the initial input."""
+
+    type: Optional[Literal["text"]] = None
+    """Input content type."""
+
+
+class CreatorPrincipal(BaseModel):
+    """Credential-free creator identity stored with the schedule.
+
+    Never carries cookies, JWTs, API keys, OAuth tokens, or request headers — it
+    is creator *context* used only for AuthZ and ownership at fire time.
+    """
+
+    account_id: Optional[str] = None
+    """Account/workspace id of the creator."""
+
+    principal_type: Optional[str] = None
+    """e.g. 'user' or 'service_account'."""
+
+    service_account_id: Optional[str] = None
+    """Creator service-account id, if a service principal."""
+
+    user_id: Optional[str] = None
+    """Creator user id, if a user principal."""
+
+
+class ScheduleResumeResponse(BaseModel):
+    """Response model describing a scheduled agent run."""
+
+    id: str
+    """The unique identifier of the run schedule."""
+
+    agent_id: str
+    """The agent this schedule belongs to."""
+
+    initial_input: InitialInput
+    """The initial input."""
+
+    initial_input_method: str
+    """Delivery method, inferred from the agent's ACP type."""
+
+    name: str
+    """Human-readable schedule name."""
+
+    created_at: Optional[datetime] = None
+    """When the schedule was created."""
+
+    creator_principal: Optional[CreatorPrincipal] = None
+    """Credential-free creator identity stored with the schedule.
+
+    Never carries cookies, JWTs, API keys, OAuth tokens, or request headers — it is
+    creator _context_ used only for AuthZ and ownership at fire time.
+    """
+
+    cron_expression: Optional[str] = None
+    """Cron cadence, if cron-based."""
+
+    description: Optional[str] = None
+    """Optional description."""
+
+    end_at: Optional[datetime] = None
+    """Schedule deactivation time."""
+
+    interval_seconds: Optional[int] = None
+    """Interval cadence in seconds, if interval-based."""
+
+    last_action_time: Optional[datetime] = None
+    """When the schedule last fired."""
+
+    next_action_times: Optional[List[datetime]] = None
+    """Upcoming scheduled fire times."""
+
+    num_actions_taken: Optional[int] = None
+    """Number of times the schedule has fired."""
+
+    paused: Optional[bool] = None
+    """Whether the schedule is paused."""
+
+    start_at: Optional[datetime] = None
+    """Schedule activation time."""
+
+    state: Optional[Literal["ACTIVE", "PAUSED"]] = None
+    """Live schedule state from Temporal."""
+
+    task_metadata: Optional[Dict[str, object]] = None
+    """Task metadata at fire time."""
+
+    task_params: Optional[Dict[str, object]] = None
+    """Task params at fire time."""
+
+    timezone: Optional[str] = None
+    """Timezone the cron expression is evaluated in."""
+
+    updated_at: Optional[datetime] = None
+    """When the schedule was updated."""