Merge branch 'main' into stas/trace-agentex-source

Author: smoreinis

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.4.18"
+  ".": "0.4.20"
 }

CHANGELOG.md

@@ -1,5 +1,17 @@
 # Changelog
 
+## 0.4.20 (2025-10-01)
+
+Full Changelog: [v0.4.19...v0.4.20](https://github.com/scaleapi/agentex-python/compare/v0.4.19...v0.4.20)
+
+## 0.4.19 (2025-10-01)
+
+Full Changelog: [v0.4.18...v0.4.19](https://github.com/scaleapi/agentex-python/compare/v0.4.18...v0.4.19)
+
+### Features
+
+* Adds helm config to Agent Environment ([#125](https://github.com/scaleapi/agentex-python/issues/125)) ([e4b39b5](https://github.com/scaleapi/agentex-python/commit/e4b39b5f319452bbc6650a7ef41b3a3179bb3b93))
+
 ## 0.4.18 (2025-09-29)
 
 Full Changelog: [v0.4.17...v0.4.18](https://github.com/scaleapi/agentex-python/compare/v0.4.17...v0.4.18)

examples/launch-tutorials.sh

@@ -118,9 +118,14 @@ run_tutorial() {
     print_colored $GREEN "🚀 Executing: cd .. && uv run agentex agents run --manifest examples/$manifest_path"
     print_colored $YELLOW "💡 Press Ctrl+C to stop the tutorial"
     echo ""
-    
+
     # Run the tutorial directly (need to go to parent dir where uv project is)
-    (cd .. && uv run agentex agents run --manifest "examples/$manifest_path")
+    # Load .env file if it exists and pass variables to the subshell
+    if [[ -f "../.env" ]]; then
+        (cd .. && set -a && source .env && set +a && uv run agentex agents run --manifest "examples/$manifest_path")
+    else
+        (cd .. && uv run agentex agents run --manifest "examples/$manifest_path")
+    fi
 
     local exit_code=$?
     if [[ $exit_code -eq 0 ]]; then

examples/tutorials/00_sync/000_hello_acp/dev.ipynb

@@ -93,9 +93,8 @@
    "outputs": [],
    "source": [
     "# Test streaming response\n",
-    "from agentex.types.task_message_update import StreamTaskMessageDelta, StreamTaskMessageFull\n",
     "from agentex.types.text_delta import TextDelta\n",
-    "\n",
+    "from agentex.types.task_message_update import StreamTaskMessageFull, StreamTaskMessageDelta\n",
     "\n",
     "# The result object of message/send will be a TaskMessageUpdate which is a union of the following types:\n",
     "# - StreamTaskMessageStart: \n",

examples/tutorials/00_sync/000_hello_acp/project/acp.py

@@ -1,11 +1,11 @@
-from typing import AsyncGenerator, Union
-from agentex.lib.sdk.fastacp.fastacp import FastACP
-from agentex.lib.types.acp import SendMessageParams
+from typing import Union, AsyncGenerator
 
-from agentex.types.task_message_update import TaskMessageUpdate
+from agentex.lib.types.acp import SendMessageParams
+from agentex.lib.utils.logging import make_logger
 from agentex.types.task_message import TaskMessageContent
+from agentex.lib.sdk.fastacp.fastacp import FastACP
+from agentex.types.task_message_update import TaskMessageUpdate
 from agentex.types.task_message_content import TextContent
-from agentex.lib.utils.logging import make_logger
 
 logger = make_logger(__name__)
 
@@ -21,8 +21,15 @@ async def handle_message_send(
     params: SendMessageParams
 ) -> Union[TaskMessageContent, AsyncGenerator[TaskMessageUpdate, None]]:
     """Default message handler with streaming support"""
+    # Extract content safely from the message
+    message_text = ""
+    if hasattr(params.content, 'content'):
+        content_val = getattr(params.content, 'content', '')
+        if isinstance(content_val, str):
+            message_text = content_val
+
     return TextContent(
         author="agent",
-        content=f"Hello! I've received your message. Here's a generic response, but in future tutorials we'll see how you can get me to intelligently respond to your message. This is what I heard you say: {params.content.content}",
+        content=f"Hello! I've received your message. Here's a generic response, but in future tutorials we'll see how you can get me to intelligently respond to your message. This is what I heard you say: {message_text}",
     )
 

examples/tutorials/00_sync/010_multiturn/dev.ipynb

@@ -93,9 +93,8 @@
    "outputs": [],
    "source": [
     "# Test streaming response\n",
-    "from agentex.types.task_message_update import StreamTaskMessageDelta, StreamTaskMessageFull\n",
     "from agentex.types.text_delta import TextDelta\n",
-    "\n",
+    "from agentex.types.task_message_update import StreamTaskMessageFull, StreamTaskMessageDelta\n",
     "\n",
     "# The result object of message/send will be a TaskMessageUpdate which is a union of the following types:\n",
     "# - StreamTaskMessageStart: \n",

examples/tutorials/00_sync/010_multiturn/project/acp.py

@@ -1,14 +1,14 @@
 import os
-from typing import AsyncGenerator, Union
+from typing import Union, AsyncGenerator
 
 from agentex.lib import adk
-from agentex.lib.sdk.fastacp.fastacp import FastACP
 from agentex.lib.types.acp import SendMessageParams
-from agentex.lib.types.llm_messages import AssistantMessage, LLMConfig, SystemMessage, UserMessage
-from agentex.types.task_message_update import TaskMessageUpdate
 from agentex.types.task_message import TaskMessageContent
-from agentex.types.task_message_content import TextContent
 from agentex.lib.utils.model_utils import BaseModel
+from agentex.lib.types.llm_messages import LLMConfig, UserMessage, SystemMessage, AssistantMessage
+from agentex.lib.sdk.fastacp.fastacp import FastACP
+from agentex.types.task_message_update import TaskMessageUpdate
+from agentex.types.task_message_content import TextContent
 
 # Create an ACP server
 acp = FastACP.create(
@@ -33,11 +33,11 @@ async def handle_message_send(
     # 0. Validate the message.
     #########################################################
 
-    if params.content.type != "text":
-        raise ValueError(f"Expected text message, got {params.content.type}")
+    if not hasattr(params.content, 'type') or params.content.type != "text":
+        raise ValueError(f"Expected text message, got {getattr(params.content, 'type', 'unknown')}")
 
-    if params.content.author != "user":
-        raise ValueError(f"Expected user message, got {params.content.author}")
+    if not hasattr(params.content, 'author') or params.content.author != "user":
+        raise ValueError(f"Expected user message, got {getattr(params.content, 'author', 'unknown')}")
 
     if not os.environ.get("OPENAI_API_KEY"):
         return TextContent(
@@ -74,9 +74,9 @@ async def handle_message_send(
     llm_messages = [
         SystemMessage(content=state.system_prompt),
         *[
-            UserMessage(content=message.content.content) if message.content.author == "user" else AssistantMessage(content=message.content.content)
+            UserMessage(content=getattr(message.content, 'content', '')) if getattr(message.content, 'author', None) == "user" else AssistantMessage(content=getattr(message.content, 'content', ''))
             for message in task_messages
-            if message.content.type == "text"
+            if getattr(message.content, 'type', None) == "text"
         ]
     ]
 

examples/tutorials/00_sync/020_streaming/dev.ipynb

@@ -93,9 +93,8 @@
    "outputs": [],
    "source": [
     "# Test streaming response\n",
-    "from agentex.types.task_message_update import StreamTaskMessageDelta, StreamTaskMessageFull\n",
     "from agentex.types.text_delta import TextDelta\n",
-    "\n",
+    "from agentex.types.task_message_update import StreamTaskMessageFull, StreamTaskMessageDelta\n",
     "\n",
     "# The result object of message/send will be a TaskMessageUpdate which is a union of the following types:\n",
     "# - StreamTaskMessageStart: \n",

examples/tutorials/00_sync/020_streaming/project/acp.py

@@ -1,14 +1,19 @@
 import os
-from typing import AsyncGenerator, Union
+from typing import Union, AsyncGenerator
 
 from agentex.lib import adk
-from agentex.lib.sdk.fastacp.fastacp import FastACP
 from agentex.lib.types.acp import SendMessageParams
-from agentex.lib.types.llm_messages import AssistantMessage, LLMConfig, SystemMessage, UserMessage
-from agentex.types.task_message_update import StreamTaskMessageDelta, StreamTaskMessageDone, StreamTaskMessageFull, TaskMessageUpdate
-from agentex.types.task_message_delta import TextDelta
 from agentex.lib.utils.model_utils import BaseModel
-from agentex.types.task_message_content import TaskMessageContent, TextContent
+from agentex.lib.types.llm_messages import LLMConfig, UserMessage, SystemMessage, AssistantMessage
+from agentex.lib.sdk.fastacp.fastacp import FastACP
+from agentex.types.task_message_delta import TextDelta
+from agentex.types.task_message_update import (
+    TaskMessageUpdate,
+    StreamTaskMessageDone,
+    StreamTaskMessageFull,
+    StreamTaskMessageDelta,
+)
+from agentex.types.task_message_content import TextContent, TaskMessageContent
 
 # Create an ACP server
 acp = FastACP.create(
@@ -36,11 +41,11 @@ async def handle_message_send(
     if not params.content:
         return
 
-    if params.content.type != "text":
-        raise ValueError(f"Expected text message, got {params.content.type}")
+    if not hasattr(params.content, 'type') or params.content.type != "text":
+        raise ValueError(f"Expected text message, got {getattr(params.content, 'type', 'unknown')}")
 
-    if params.content.author != "user":
-        raise ValueError(f"Expected user message, got {params.content.author}")
+    if not hasattr(params.content, 'author') or params.content.author != "user":
+        raise ValueError(f"Expected user message, got {getattr(params.content, 'author', 'unknown')}")
 
     if not os.environ.get("OPENAI_API_KEY"):
         yield StreamTaskMessageFull(
@@ -67,9 +72,9 @@ async def handle_message_send(
     llm_messages = [
         SystemMessage(content=state.system_prompt),
         *[
-            UserMessage(content=message.content.content) if message.content.author == "user" else AssistantMessage(content=message.content.content)
+            UserMessage(content=getattr(message.content, 'content', '')) if getattr(message.content, 'author', None) == "user" else AssistantMessage(content=getattr(message.content, 'content', ''))
             for message in task_messages
-            if message.content and message.content.type == "text"
+            if message.content and getattr(message.content, 'type', None) == "text"
         ]
     ]
 
@@ -92,7 +97,7 @@ async def handle_message_send(
             yield StreamTaskMessageDelta(
                 type="delta",
                 index=message_index,
-                delta=TextDelta(text_delta=chunk.choices[0].delta.content or ""),
+                delta=TextDelta(type="text", text_delta=chunk.choices[0].delta.content or ""),
             )
 
     yield StreamTaskMessageDone(

examples/tutorials/10_agentic/00_base/000_hello_acp/project/acp.py

@@ -1,11 +1,11 @@
 import json
+
 from agentex.lib import adk
-from agentex.lib.sdk.fastacp.fastacp import FastACP
+from agentex.lib.types.acp import SendEventParams, CancelTaskParams, CreateTaskParams
 from agentex.lib.types.fastacp import AgenticACPConfig
-from agentex.lib.types.acp import CancelTaskParams, CreateTaskParams, SendEventParams
-
-from agentex.types.text_content import TextContent
 from agentex.lib.utils.logging import make_logger
+from agentex.types.text_content import TextContent
+from agentex.lib.sdk.fastacp.fastacp import FastACP
 
 logger = make_logger(__name__)