more fixs

Author: RoxyFarhad

examples/tutorials/00_sync/000_hello_acp/Dockerfile

@@ -38,14 +38,14 @@ COPY 00_sync/000_hello_acp/tests /app/000_hello_acp/tests
 # Copy shared test utilities
 COPY test_utils /app/test_utils
 
-# Install the required Python packages with dev dependencies (includes pytest)
-RUN uv pip install --system .[dev] pytest-asyncio httpx
+# Install the required Python packages with dev dependencies
+RUN uv pip install --system .[dev]
 
 # Set environment variables
 ENV PYTHONPATH=/app
 
 # Set test environment variables
-ENV AGENT_NAME=s000-hello-acp
+ENV AGENT_NAME=000-hello-acp
 
 # Run the agent using uvicorn
 CMD ["uvicorn", "project.acp:acp", "--host", "0.0.0.0", "--port", "8000"] 

examples/tutorials/00_sync/000_hello_acp/pyproject.toml

@@ -3,21 +3,22 @@ requires = ["hatchling"]
 build-backend = "hatchling.build"
 
 [project]
-name = "s000-hello-acp"
+name = "000-hello-acp"
 version = "0.1.0"
 description = "An AgentEx agent that just says hello and acknowledges the user's message"
 readme = "README.md"
 requires-python = ">=3.12"
 dependencies = [
     "agentex-sdk",
     "scale-gp",
-    "pytest",
-    "pytest-xdist"
 ]
 
 [project.optional-dependencies]
 dev = [
     "pytest",
+    "pytest-asyncio",
+    "pytest-xdist",
+    "httpx",
     "black",
     "isort",
     "flake8",

examples/tutorials/00_sync/010_multiturn/Dockerfile

@@ -37,15 +37,15 @@ COPY 00_sync/010_multiturn/tests /app/010_multiturn/tests
 # Copy shared test utilities
 COPY test_utils /app/test_utils
 
-# Install the required Python packages with dev dependencies (includes pytest)
-RUN uv pip install --system .[dev] pytest-asyncio httpx
+# Install the required Python packages with dev dependencies
+RUN uv pip install --system .[dev]
 
 WORKDIR /app/010_multiturn
 # Set environment variables
 ENV PYTHONPATH=/app
 
 # Set test environment variables
-ENV AGENT_NAME=s010-multiturn
+ENV AGENT_NAME=010-multiturn
 
 # Run the agent using uvicorn
 CMD ["uvicorn", "project.acp:acp", "--host", "0.0.0.0", "--port", "8000"] 

examples/tutorials/00_sync/010_multiturn/pyproject.toml

@@ -3,7 +3,7 @@ requires = ["hatchling"]
 build-backend = "hatchling.build"
 
 [project]
-name = "s010-multiturn"
+name = "010-multiturn"
 version = "0.1.0"
 description = "An AgentEx agent"
 readme = "README.md"
@@ -16,6 +16,8 @@ dependencies = [
 [project.optional-dependencies]
 dev = [
     "pytest",
+    "pytest-asyncio",
+    "httpx",
     "black",
     "isort",
     "flake8",

examples/tutorials/00_sync/020_streaming/Dockerfile

@@ -37,14 +37,14 @@ COPY 00_sync/020_streaming/tests /app/020_streaming/tests
 # Copy shared test utilities
 COPY test_utils /app/test_utils
 
-# Install the required Python packages with dev dependencies (includes pytest)
-RUN uv pip install --system .[dev] pytest-asyncio httpx
+# Install the required Python packages with dev dependencies
+RUN uv pip install --system .[dev]
 
 # Set environment variables
 ENV PYTHONPATH=/app
 
 # Set test environment variables
-ENV AGENT_NAME=s020-streaming
+ENV AGENT_NAME=020-streaming
 
 # Run the agent using uvicorn
 CMD ["uvicorn", "project.acp:acp", "--host", "0.0.0.0", "--port", "8000"]

examples/tutorials/00_sync/020_streaming/pyproject.toml

@@ -3,7 +3,7 @@ requires = ["hatchling"]
 build-backend = "hatchling.build"
 
 [project]
-name = "s020-streaming"
+name = "020-streaming"
 version = "0.1.0"
 description = "An AgentEx agent that does multiturn streaming chat"
 readme = "README.md"
@@ -16,6 +16,8 @@ dependencies = [
 [project.optional-dependencies]
 dev = [
     "pytest",
+    "pytest-asyncio",
+    "httpx",
     "black",
     "isort",
     "flake8",

examples/tutorials/test_utils/async_utils.py

@@ -126,7 +126,19 @@ async def poll_messages(
             if yield_updates:
                 # For streaming: track content changes
                 content_str = message.content.content if message.content and hasattr(message.content, 'content') else ""
-                content_hash = hash(content_str + str(message.streaming_status))
+                # Ensure content_str is always a string to avoid concatenation errors
+                if isinstance(content_str, list):
+                    # If it's a list, convert to string representation
+                    content_str = str(content_str)
+                elif content_str is None:
+                    content_str = ""
+                elif not isinstance(content_str, str):
+                    # Handle any other non-string types
+                    content_str = str(content_str)
+
+                # Ensure streaming_status is also properly converted to string
+                streaming_status_str = str(message.streaming_status) if message.streaming_status is not None else ""
+                content_hash = hash(content_str + streaming_status_str)
                 is_updated = message.id in message_content_hashes and message_content_hashes[message.id] != content_hash
 
                 if is_new_message or is_updated: