[Chore] Make Linting great again

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__)
 

examples/tutorials/10_agentic/00_base/010_multiturn/project/acp.py

@@ -2,23 +2,23 @@
 from typing import List
 
 from agentex.lib import adk
-from agentex.lib.core.tracing.tracing_processor_manager import (
-    add_tracing_processor_config,
-)
-from agentex.lib.sdk.fastacp.fastacp import FastACP
-from agentex.lib.types.acp import CancelTaskParams, CreateTaskParams, SendEventParams
+from agentex.lib.types.acp import SendEventParams, CancelTaskParams, CreateTaskParams
 from agentex.lib.types.fastacp import AgenticACPConfig
+from agentex.lib.types.tracing import SGPTracingProcessorConfig
+from agentex.lib.utils.logging import make_logger
+from agentex.types.text_content import TextContent
+from agentex.lib.utils.model_utils import BaseModel
 from agentex.lib.types.llm_messages import (
-    AssistantMessage,
-    LLMConfig,
     Message,
-    SystemMessage,
+    LLMConfig,
     UserMessage,
+    SystemMessage,
+    AssistantMessage,
+)
+from agentex.lib.sdk.fastacp.fastacp import FastACP
+from agentex.lib.core.tracing.tracing_processor_manager import (
+    add_tracing_processor_config,
 )
-from agentex.lib.types.tracing import SGPTracingProcessorConfig
-from agentex.lib.utils.logging import make_logger
-from agentex.lib.utils.model_utils import BaseModel
-from agentex.types.text_content import TextContent
 
 logger = make_logger(__name__)
 
@@ -97,13 +97,21 @@ async def handle_event_send(params: SendEventParams):
     #########################################################
 
     task_state = await adk.state.get_by_task_and_agent(task_id=params.task.id, agent_id=params.agent.id)
+    if not task_state:
+        raise ValueError("Task state not found - ensure task was properly initialized")
     state = StateModel.model_validate(task_state.state)
 
     #########################################################
     # 6. (👋) Add the new user message to the message history
     #########################################################
 
-    state.messages.append(UserMessage(content=params.event.content.content))
+    # Safely extract content from the event
+    content_text = ""
+    if hasattr(params.event.content, 'content'):
+        content_val = getattr(params.event.content, 'content', '')
+        if isinstance(content_val, str):
+            content_text = content_val
+    state.messages.append(UserMessage(content=content_text))
 
     #########################################################
     # 7. (👋) Call an LLM to respond to the user's message
@@ -114,7 +122,10 @@ async def handle_event_send(params: SendEventParams):
         llm_config=LLMConfig(model="gpt-4o-mini", messages=state.messages),
         trace_id=params.task.id,
     )
-    state.messages.append(AssistantMessage(content=chat_completion.choices[0].message.content))
+    response_content = ""
+    if chat_completion.choices[0].message:
+        response_content = chat_completion.choices[0].message.content or ""
+    state.messages.append(AssistantMessage(content=response_content))
 
     #########################################################
     # 8. (👋) Send agent response to client 

examples/tutorials/10_agentic/00_base/020_streaming/project/acp.py

@@ -2,13 +2,13 @@
 from typing import List
 
 from agentex.lib import adk
-from agentex.lib.sdk.fastacp.fastacp import FastACP
-from agentex.lib.types.acp import CancelTaskParams, CreateTaskParams, SendEventParams
+from agentex.lib.types.acp import SendEventParams, CancelTaskParams, CreateTaskParams
 from agentex.lib.types.fastacp import AgenticACPConfig
-from agentex.lib.types.llm_messages import AssistantMessage, LLMConfig, Message, SystemMessage, UserMessage
 from agentex.lib.utils.logging import make_logger
-from agentex.lib.utils.model_utils import BaseModel
 from agentex.types.text_content import TextContent
+from agentex.lib.utils.model_utils import BaseModel
+from agentex.lib.types.llm_messages import Message, LLMConfig, UserMessage, SystemMessage, AssistantMessage
+from agentex.lib.sdk.fastacp.fastacp import FastACP
 
 logger = make_logger(__name__)
 
@@ -82,13 +82,21 @@ async def handle_event_send(params: SendEventParams):
     #########################################################
 
     task_state = await adk.state.get_by_task_and_agent(task_id=params.task.id, agent_id=params.agent.id)
+    if not task_state:
+        raise ValueError("Task state not found - ensure task was properly initialized")
     state = StateModel.model_validate(task_state.state)
 
     #########################################################
     # 6. Add the new user message to the message history
     #########################################################
 
-    state.messages.append(UserMessage(content=params.event.content.content))
+    # Safely extract content from the event
+    content_text = ""
+    if hasattr(params.event.content, 'content'):
+        content_val = getattr(params.event.content, 'content', '')
+        if isinstance(content_val, str):
+            content_text = content_val
+    state.messages.append(UserMessage(content=content_text))
 
     #########################################################
     # 7. (👋) Call an LLM to respond to the user's message
@@ -109,7 +117,13 @@ async def handle_event_send(params: SendEventParams):
         trace_id=params.task.id,
     )
 
-    state.messages.append(AssistantMessage(content=task_message.content.content))
+    # Safely extract content from the task message
+    response_text = ""
+    if task_message.content and hasattr(task_message.content, 'content'):  # type: ignore[union-attr]
+        content_val = getattr(task_message.content, 'content', '')  # type: ignore[union-attr]
+        if isinstance(content_val, str):
+            response_text = content_val
+    state.messages.append(AssistantMessage(content=response_text))
 
     #########################################################
     # 8. Store the messages in the task state for the next turn