Release 0.7.0b1

Author: fern-api[bot]

README.md

@@ -68,6 +68,29 @@ except ApiError as e:
     print(e.body)
 ```
 
+## Streaming
+
+The SDK supports streaming responses, as well, the response will be a generator that you can loop over.
+
+```python
+from letta import Letta, MessageCreate
+
+client = Letta(
+    token="YOUR_TOKEN",
+)
+response = client.agents.stream_message(
+    agent_id="agent_id",
+    messages=[
+        MessageCreate(
+            role="user",
+            text="text",
+        )
+    ],
+)
+for chunk in response:
+    yield chunk
+```
+
 ## Advanced
 
 ### Retries

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "letta"
-version = "0.7.0b0"
+version = "0.7.0b1"
 description = ""
 readme = "README.md"
 authors = []

reference.md

@@ -3836,6 +3836,118 @@ client.agents.update_message(
 </dl>
 
 
+</dd>
+</dl>
+</details>
+
+<details><summary><code>client.agents.<a href="src/letta/agents/client.py">stream_message</a>(...)</code></summary>
+<dl>
+<dd>
+
+#### 📝 Description
+
+<dl>
+<dd>
+
+<dl>
+<dd>
+
+Process a user message and return the agent's response.
+This endpoint accepts a message from a user and processes it through the agent.
+It will stream the steps of the response always, and stream the tokens if 'stream_tokens' is set to True.
+</dd>
+</dl>
+</dd>
+</dl>
+
+#### 🔌 Usage
+
+<dl>
+<dd>
+
+<dl>
+<dd>
+
+```python
+from letta import Letta, MessageCreate
+
+client = Letta(
+    token="YOUR_TOKEN",
+)
+response = client.agents.stream_message(
+    agent_id="agent_id",
+    messages=[
+        MessageCreate(
+            role="user",
+            text="text",
+        )
+    ],
+)
+for chunk in response:
+    yield chunk
+
+```
+</dd>
+</dl>
+</dd>
+</dl>
+
+#### ⚙️ Parameters
+
+<dl>
+<dd>
+
+<dl>
+<dd>
+
+**agent_id:** `str` 
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**messages:** `LettaStreamingRequestMessages` — The messages to be sent to the agent.
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**assistant_message_tool_name:** `typing.Optional[str]` — The name of the designated message tool.
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**assistant_message_tool_kwarg:** `typing.Optional[str]` — The name of the message argument in the designated message tool.
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**stream_tokens:** `typing.Optional[bool]` — Flag to determine if individual tokens should be streamed. Set to True for token streaming (requires stream_steps = True).
+    
+</dd>
+</dl>
+
+<dl>
+<dd>
+
+**request_options:** `typing.Optional[RequestOptions]` — Request-specific configuration.
+    
+</dd>
+</dl>
+</dd>
+</dl>
+
+
 </dd>
 </dl>
 </details>

src/letta/agents/client.py

@@ -1888,6 +1888,25 @@ def stream_message(
         ------
         typing.Iterator[LettaStreamingResponse]
             Successful response
+
+        Examples
+        --------
+        from letta import Letta, MessageCreate
+
+        client = Letta(
+            token="YOUR_TOKEN",
+        )
+        response = client.agents.stream_message(
+            agent_id="agent_id",
+            messages=[
+                MessageCreate(
+                    role="user",
+                    text="text",
+                )
+            ],
+        )
+        for chunk in response:
+            yield chunk
         """
         with self._client_wrapper.httpx_client.stream(
             f"v1/agents/{jsonable_encoder(agent_id)}/messages/stream",
@@ -4165,6 +4184,33 @@ async def stream_message(
         ------
         typing.AsyncIterator[LettaStreamingResponse]
             Successful response
+
+        Examples
+        --------
+        import asyncio
+
+        from letta import AsyncLetta, MessageCreate
+
+        client = AsyncLetta(
+            token="YOUR_TOKEN",
+        )
+
+
+        async def main() -> None:
+            response = await client.agents.stream_message(
+                agent_id="agent_id",
+                messages=[
+                    MessageCreate(
+                        role="user",
+                        text="text",
+                    )
+                ],
+            )
+            async for chunk in response:
+                yield chunk
+
+
+        asyncio.run(main())
         """
         async with self._client_wrapper.httpx_client.stream(
             f"v1/agents/{jsonable_encoder(agent_id)}/messages/stream",

src/letta/core/client_wrapper.py

@@ -22,7 +22,7 @@ def get_headers(self) -> typing.Dict[str, str]:
         headers: typing.Dict[str, str] = {
             "X-Fern-Language": "Python",
             "X-Fern-SDK-Name": "letta",
-            "X-Fern-SDK-Version": "0.7.0b0",
+            "X-Fern-SDK-Version": "0.7.0b1",
         }
         headers["Authorization"] = f"Bearer {self._get_token()}"
         return headers