Merge pull request #75 from scaleapi/fs/reasoning

support reasoning

Author: felixs8696

.gitignore

@@ -13,3 +13,5 @@ dist
 .envrc
 codegen.log
 Brewfile.lock.json
+
+.DS_Store

examples/tutorials/10_agentic/10_temporal/010_agent_chat/project/workflow.py

@@ -6,6 +6,8 @@
 from agentex.lib.utils.model_utils import BaseModel
 from mcp import StdioServerParameters
 from temporalio import workflow
+from agents import ModelSettings
+from openai.types.shared import Reasoning
 
 from agentex.lib import adk
 from agentex.lib.types.acp import CreateTaskParams, SendEventParams
@@ -117,6 +119,13 @@ async def on_task_event_send(self, params: SendEventParams) -> None:
                 You have access to sequential thinking and web search capabilities through MCP servers.
                 Use these tools when appropriate to provide accurate and well-reasoned responses.""",
                 parent_span_id=span.id if span else None,
+                model="o4-mini",
+                model_settings=ModelSettings(
+                    # Include reasoning items in the response (IDs, summaries)
+                    # response_include=["reasoning.encrypted_content"],
+                    # Ask the model to include a short reasoning summary
+                    reasoning=Reasoning(effort="medium", summary="auto"),
+                )
             )
             self._state.input_list = run_result.final_input_list
 

examples/tutorials/10_agentic/10_temporal/020_state_machine/dev.ipynb

@@ -159,7 +159,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.12.9"
+   "version": "3.12.11"
   }
  },
  "nbformat": 4,

pyproject.toml

@@ -38,7 +38,8 @@ dependencies = [
     "pytest>=8.4.0",
     "pytest-asyncio>=1.0.0",
     "scale-gp-beta==0.1.0a20",
-    "ipykernel>=6.29.5",    
+    "ipykernel>=6.29.5",
+    "openai>=1.99.9",
 ]
 requires-python = ">= 3.12,<4"
 classifiers = [

src/agentex/lib/core/services/adk/providers/openai.py

@@ -29,6 +29,7 @@
 )
 from agentex.types.task_message_content import (
     TextContent,
+    ReasoningContent,
     ToolRequestContent,
     ToolResponseContent,
 )
@@ -647,6 +648,31 @@ async def run_agent_streamed_auto_send(
                                             content=tool_response_content,
                                         ),
                                     )
+                            
+                            elif event.item.type == "reasoning_item":
+                                # Handle reasoning items
+                                reasoning_item = event.item.raw_item
+                                
+                                reasoning_content = ReasoningContent(
+                                    author="agent",
+                                    summary=[summary.text for summary in reasoning_item.summary],
+                                    content=[content.text for content in reasoning_item.content] if reasoning_item.content else None,
+                                )
+
+                                # Create reasoning content using streaming context (immediate completion)
+                                async with (
+                                    self.streaming_service.streaming_task_message_context(
+                                        task_id=task_id,
+                                        initial_content=reasoning_content,
+                                    ) as streaming_context
+                                ):
+                                    # The message has already been persisted, but we still need to send an update
+                                    await streaming_context.stream_update(
+                                        update=StreamTaskMessageFull(
+                                            parent_task_message=streaming_context.task_message,
+                                            content=reasoning_content,
+                                        ),
+                                    )
 
                         elif event.type == "raw_response_event":
                             if isinstance(event.data, ResponseTextDeltaEvent):