fix(openai): forward previous_response_id in run_agent_streamed_auto_send [greptile]

The unified-surface migration of run_agent_streamed_auto_send dropped
previous_response_id: it was accepted (suppressed by noqa: ARG002) but never
passed to Runner.run_streamed, so any caller continuing a Responses-API
conversation silently started a fresh one. Mirror the non-auto-send
run_agent_streamed branching (max_turns x previous_response_id) and drop the
now-incorrect noqa. The activity layer already forwarded params.previous_response_id.
Adds a test asserting the id reaches Runner.run_streamed.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: declan-scale

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

@@ -678,7 +678,7 @@ async def run_agent_streamed_auto_send(
         input_guardrails: list[InputGuardrail] | None = None,
         output_guardrails: list[OutputGuardrail] | None = None,
         max_turns: int | None = None,
-        previous_response_id: str | None = None,  # noqa: ARG002
+        previous_response_id: str | None = None,
         created_at: datetime | None = None,
     ) -> RunResultStreaming:
         """
@@ -785,9 +785,23 @@ async def run_agent_streamed_auto_send(
 
                 agent = Agent(**agent_kwargs)
 
-                # Run with streaming
-                if max_turns is not None:
+                # Run with streaming. Forward previous_response_id so callers that
+                # continue a Responses-API conversation resume the prior response
+                # instead of silently starting a fresh one (mirrors the non-auto-send
+                # run_agent_streamed path).
+                if max_turns is not None and previous_response_id is not None:
+                    result = Runner.run_streamed(
+                        starting_agent=agent,
+                        input=input_list,
+                        max_turns=max_turns,
+                        previous_response_id=previous_response_id,
+                    )
+                elif max_turns is not None:
                     result = Runner.run_streamed(starting_agent=agent, input=input_list, max_turns=max_turns)
+                elif previous_response_id is not None:
+                    result = Runner.run_streamed(
+                        starting_agent=agent, input=input_list, previous_response_id=previous_response_id
+                    )
                 else:
                     result = Runner.run_streamed(starting_agent=agent, input=input_list)
 

tests/lib/adk/providers/test_openai_activities.py

@@ -354,6 +354,43 @@ async def mock_stream_events():
         assert second.type == "tool_response"
         assert second.tool_call_id == "code_interpreter_call_123"
 
+    @patch("agents.Runner.run_streamed")
+    async def test_run_agent_streamed_auto_send_forwards_previous_response_id(self, mock_runner_run_streamed):
+        """previous_response_id must reach Runner.run_streamed so a Responses-API
+        conversation continues instead of silently starting fresh."""
+        from agentex.lib.core.temporal.activities.adk.providers.openai_activities import (
+            RunAgentStreamedAutoSendParams,
+        )
+
+        mock_streaming_result = self._create_streaming_result_mock()
+
+        async def _no_events():
+            return
+            yield
+
+        mock_streaming_result.stream_events = _no_events
+        mock_runner_run_streamed.return_value = mock_streaming_result
+
+        mock_tracer = self._create_mock_tracer()
+        openai_service, openai_activities, env = self._create_test_setup(mock_tracer)
+        self._setup_streaming_service_mocks(openai_service)
+
+        params = RunAgentStreamedAutoSendParams(
+            input_list=[{"role": "user", "content": "continue"}],
+            mcp_server_params=[],
+            agent_name="test_agent",
+            agent_instructions="You are a helpful assistant",
+            trace_id="test-trace-id",
+            parent_span_id="test-span-id",
+            task_id="test-task-id",
+            previous_response_id="response_123",
+        )
+
+        await env.run(openai_activities.run_agent_streamed_auto_send, params)
+
+        mock_runner_run_streamed.assert_called_once()
+        assert mock_runner_run_streamed.call_args.kwargs.get("previous_response_id") == "response_123"
+
     def _create_mock_tracer(self):
         """Helper method to create a properly mocked tracer with async context manager support."""
         mock_tracer = Mock()