|
41 | 41 | if TYPE_CHECKING: |
42 | 42 | from typing import Any |
43 | 43 |
|
| 44 | + from agents.run_internal.run_steps import SingleStepResult |
| 45 | + |
44 | 46 |
|
45 | 47 | def _patch_runner() -> None: |
46 | 48 | # Create the root span for one full agent run (including eventual handoffs) |
@@ -119,7 +121,9 @@ def new_wrapped_get_model( |
119 | 121 | agents.run_internal.run_loop.get_model = new_wrapped_get_model |
120 | 122 |
|
121 | 123 | @wraps(run_loop.run_single_turn) |
122 | | - async def patched_run_single_turn(*args: "Any", **kwargs: "Any") -> "Any": |
| 124 | + async def patched_run_single_turn( |
| 125 | + *args: "Any", **kwargs: "Any" |
| 126 | + ) -> "SingleStepResult": |
123 | 127 | return await _run_single_turn(run_loop.run_single_turn, *args, **kwargs) |
124 | 128 |
|
125 | 129 | agents.run.run_single_turn = patched_run_single_turn |
@@ -150,10 +154,10 @@ def old_wrapped_get_model( |
150 | 154 |
|
151 | 155 | original_run_single_turn = AgentRunner._run_single_turn |
152 | 156 |
|
153 | | - @wraps(AgentRunner._run_single_turn) |
| 157 | + @wraps(AgentRunner._run_single_turn.__func__) |
154 | 158 | async def old_wrapped_run_single_turn( |
155 | 159 | cls: "agents.Runner", *args: "Any", **kwargs: "Any" |
156 | | - ) -> "Any": |
| 160 | + ) -> "SingleStepResult": |
157 | 161 | return await _run_single_turn(original_run_single_turn, *args, **kwargs) |
158 | 162 |
|
159 | 163 | agents.run.AgentRunner._run_single_turn = classmethod( |
|
0 commit comments