refactor(assistants): remove deprecated assistant-related files and update prompt type references in responder

Author: arthurbrenno

agentle/assistants/__init__.py renamed to agentle/autonomous_systems/__init__.py

@@ -1,12 +1,12 @@
-from collections.abc import Callable, Sequence
 import time
 import uuid
+from collections.abc import Callable, Sequence
 from typing import Any, Literal, Optional
 
 from rsb.models.base_model import BaseModel
 from rsb.models.field import Field
 
-from agentle.assistants.assistant_input_type import AssistantInputType
+from agentle.autonomous_systems.agent_input_type import AgentInputType
 from agentle.prompts.models.prompt import Prompt
 from agentle.responses.definitions.conversation_param import ConversationParam
 from agentle.responses.definitions.include_enum import IncludeEnum
@@ -21,13 +21,12 @@
 from agentle.responses.definitions.tool_choice_function import ToolChoiceFunction
 from agentle.responses.definitions.tool_choice_mcp import ToolChoiceMCP
 from agentle.responses.definitions.tool_choice_options import ToolChoiceOptions
-
 from agentle.responses.definitions.tool_choice_types import ToolChoiceTypes
 from agentle.responses.definitions.truncation import Truncation
 from agentle.responses.responder import Responder
 
 
-class Assistant[ResponseSchema = None](BaseModel):
+class Agent[ResponseSchema = None](BaseModel):
     created_at: int = Field(
         default=int(time.time()),
         description="""The time the assistant was created.""",
@@ -91,21 +90,34 @@ class Assistant[ResponseSchema = None](BaseModel):
     )
 
     include: Optional[list[IncludeEnum]] = None
+
     parallel_tool_calls: Optional[bool] = None
+
     store: Optional[bool] = None
+
     instructions: Optional[str | Prompt] = None
 
     stream_options: Optional[ResponseStreamOptions] = None
+
     conversation: Optional[str | ConversationParam] = None
+
     text_format: type[ResponseSchema] | None = None
+
     # ResponseProperties parameters
     previous_response_id: Optional[str] = None
+
     reasoning: Optional[Reasoning] = None
+
     background: Optional[bool] = None
+
     max_output_tokens: Optional[int] = None
+
     max_tool_calls: Optional[int] = None
+
     text: Optional[Text] = None
+
     tools: Optional[Sequence[Tool | Callable[..., Any]]] = None
+
     tool_choice: Optional[
         ToolChoiceOptions
         | ToolChoiceAllowed
@@ -114,17 +126,24 @@ class Assistant[ResponseSchema = None](BaseModel):
         | ToolChoiceMCP
         | ToolChoiceCustom
     ] = None
+
     prompt: Optional[Prompt] = None
+
     truncation: Optional[Truncation] = None
+
     # ModelResponseProperties parameters
     top_logprobs: Optional[int] = None
+
     user: Optional[str] = None
+
     safety_identifier: Optional[str] = None
+
     prompt_cache_key: Optional[str] = None
+
     service_tier: Optional[ServiceTier] = None
 
     async def execute_async(
         self,
-        input: AssistantInputType,
+        input: AgentInputType,
         stream: Optional[Literal[False] | Literal[True]] = None,
     ) -> Response[ResponseSchema]: ...

agentle/assistants/assistant.py renamed to agentle/autonomous_systems/agent.py

@@ -4,4 +4,4 @@
 from agentle.responses.definitions.input_item import InputItem
 
 
-AssistantInputType = Optional[str | list[InputItem] | Prompt]
+AgentInputType = Optional[str | list[InputItem] | Prompt]

agentle/assistants/assistant_input_type.py renamed to agentle/autonomous_systems/agent_input_type.py

@@ -73,7 +73,7 @@
 
 # from .drag_point import DragPoint
 
-# from .easy_input_message import EasyInputMessage
+# from .message import Message
 
 # from .file_citation_body import FileCitationBody
 
@@ -774,7 +774,7 @@
 #     'DoubleClickAction',
 #     'Drag',
 #     'DragPoint',
-#     'EasyInputMessage',
+#     'Message',
 #     'FileCitationBody',
 #     'FilePath',
 #     'FileSearchTool',

agentle/responses/definitions/__init__.py

@@ -12,7 +12,7 @@
 
 
 # Model dependencies
-from .easy_input_message import EasyInputMessage
+from .message import Message
 from .item import Item
 from .item_reference_param import ItemReferenceParam
 
@@ -22,6 +22,6 @@
 # Using Item without generic parameter since it's an Annotated type alias
 # The generic type handling is done at the Item level
 InputItem = Annotated[
-    Union[EasyInputMessage, Item, ItemReferenceParam],
+    Union[Message, Item, ItemReferenceParam],
     Field(discriminator="type"),
 ]

agentle/responses/definitions/easy_input_message.py

@@ -0,0 +1,43 @@
+# Auto-generated from responses_api.py
+# Model: Message
+
+# generated by datamodel-codegen:
+#   filename:  filtered_openapi.yaml
+#   timestamp: 2025-10-18T15:02:20+00:00
+
+from __future__ import annotations
+
+from typing import Literal
+
+from pydantic import BaseModel, Field
+
+from agentle.responses.definitions.message_content_type import MessageContentType
+
+from .role import Role
+
+
+class Message(BaseModel):
+    role: Role = Field(
+        ...,
+        description="The role of the message input. One of `user`, `assistant`, `system`, or\n`developer`.\n",
+    )
+    content: MessageContentType = Field(
+        ...,
+        description="Text, image, or audio input to the model, used to generate a response.\nCan also contain previous assistant responses.\n",
+    )
+    type: Literal["input_message"] = Field(
+        default="input_message",
+        description="The type of the message input. Always `message`.\n",
+    )
+
+    @classmethod
+    def user(cls, content: MessageContentType) -> Message:
+        return Message(role="user", content=content)
+
+    @classmethod
+    def assistant(cls, content: MessageContentType) -> Message:
+        return Message(role="assistant", content=content)
+
+    @classmethod
+    def system(cls, content: MessageContentType) -> Message:
+        return Message(role="system", content=content)

agentle/responses/definitions/input_item.py

@@ -0,0 +1,5 @@
+from typing import Union
+
+from .input_message_content_list import InputMessageContentList
+
+MessageContentType = Union[str, InputMessageContentList]

agentle/responses/definitions/message.py

@@ -6,11 +6,7 @@
 #   timestamp: 2025-10-18T15:02:20+00:00
 
 
-from enum import Enum
+from typing import Literal
 
 
-class Role(Enum):
-    user = "user"
-    assistant = "assistant"
-    system = "system"
-    developer = "developer"
+Role = Literal["user", "assistant", "system"]

agentle/responses/definitions/message_content_type.py

@@ -11,7 +11,7 @@
 from rsb.models.field import Field
 
 from agentle.generations.tracing.otel_client_type import OtelClientType
-from agentle.prompts.models.prompt import Prompt as PromptModel
+from agentle.prompts.models.prompt import Prompt as AgentlePromptType
 from agentle.responses.async_stream import AsyncStream
 from agentle.responses.definitions.conversation_param import ConversationParam
 from agentle.responses.definitions.create_response import CreateResponse
@@ -73,12 +73,12 @@ def from_openai(cls, api_key: str | None = None) -> Responder:
     async def respond_async[TextFormatT = None](
         self,
         *,
-        input: Optional[Union[str, list[InputItem], PromptModel]] = None,
+        input: Optional[Union[str, list[InputItem], AgentlePromptType]] = None,
         model: Optional[str] = None,
         include: Optional[list[IncludeEnum]] = None,
         parallel_tool_calls: Optional[bool] = None,
         store: Optional[bool] = None,
-        instructions: Optional[Union[str, PromptModel]] = None,
+        instructions: Optional[Union[str, AgentlePromptType]] = None,
         stream: Optional[Literal[False]] = False,
         stream_options: Optional[ResponseStreamOptions] = None,
         conversation: Optional[Union[str, ConversationParam]] = None,
@@ -118,12 +118,12 @@ async def respond_async[TextFormatT = None](
     async def respond_async[TextFormatT = None](
         self,
         *,
-        input: Optional[Union[str, list[InputItem], PromptModel]] = None,
+        input: Optional[Union[str, list[InputItem], AgentlePromptType]] = None,
         model: Optional[str] = None,
         include: Optional[list[IncludeEnum]] = None,
         parallel_tool_calls: Optional[bool] = None,
         store: Optional[bool] = None,
-        instructions: Optional[Union[str, PromptModel]] = None,
+        instructions: Optional[Union[str, AgentlePromptType]] = None,
         stream: Literal[True],
         stream_options: Optional[ResponseStreamOptions] = None,
         conversation: Optional[Union[str, ConversationParam]] = None,
@@ -163,12 +163,12 @@ async def respond_async[TextFormatT = None](
     async def respond_async[TextFormatT = None](
         self,
         *,
-        input: Optional[Union[str, list[InputItem], PromptModel]] = None,
+        input: Optional[Union[str, list[InputItem], AgentlePromptType]] = None,
         model: Optional[str] = None,
         include: Optional[list[IncludeEnum]] = None,
         parallel_tool_calls: Optional[bool] = None,
         store: Optional[bool] = None,
-        instructions: Optional[Union[str, PromptModel]] = None,
+        instructions: Optional[Union[str, AgentlePromptType]] = None,
         stream: bool,
         stream_options: Optional[ResponseStreamOptions] = None,
         conversation: Optional[Union[str, ConversationParam]] = None,
@@ -207,12 +207,12 @@ async def respond_async[TextFormatT = None](
     async def respond_async[TextFormatT = None](
         self,
         *,
-        input: Optional[Union[str, list[InputItem], PromptModel]] = None,
+        input: Optional[Union[str, list[InputItem], AgentlePromptType]] = None,
         model: Optional[str] = None,
         include: Optional[list[IncludeEnum]] = None,
         parallel_tool_calls: Optional[bool] = None,
         store: Optional[bool] = None,
-        instructions: Optional[Union[str, PromptModel]] = None,
+        instructions: Optional[Union[str, AgentlePromptType]] = None,
         stream: Optional[Literal[False] | Literal[True]] = None,
         stream_options: Optional[ResponseStreamOptions] = None,
         conversation: Optional[Union[str, ConversationParam]] = None,
@@ -256,13 +256,13 @@ async def respond_async[TextFormatT = None](
                     _tools.append(tool)
 
         create_response = CreateResponse(
-            input=str(input) if isinstance(input, PromptModel) else input,
+            input=str(input) if isinstance(input, AgentlePromptType) else input,
             model=model,
             include=include,
             parallel_tool_calls=parallel_tool_calls,
             store=store,
             instructions=str(instructions)
-            if isinstance(instructions, PromptModel)
+            if isinstance(instructions, AgentlePromptType)
             else instructions,
             stream=stream,
             stream_options=stream_options,