Skip to content

Commit c306cda

Browse files
authored
refactor: Remove message processor (#417)
1 parent 4b90b88 commit c306cda

File tree

4 files changed

+2
-158
lines changed

4 files changed

+2
-158
lines changed

src/strands/event_loop/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,6 @@
44
iterative manner.
55
"""
66

7-
from . import event_loop, message_processor
7+
from . import event_loop
88

9-
__all__ = ["event_loop", "message_processor"]
9+
__all__ = ["event_loop"]

src/strands/event_loop/event_loop.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
from ..types.exceptions import ContextWindowOverflowException, EventLoopException, ModelThrottledException
3030
from ..types.streaming import Metrics, StopReason
3131
from ..types.tools import ToolChoice, ToolChoiceAuto, ToolConfig, ToolGenerator, ToolResult, ToolUse
32-
from .message_processor import clean_orphaned_empty_tool_uses
3332
from .streaming import stream_messages
3433

3534
if TYPE_CHECKING:
@@ -100,9 +99,6 @@ async def event_loop_cycle(agent: "Agent", kwargs: dict[str, Any]) -> AsyncGener
10099
stream_trace = Trace("stream_messages", parent_id=cycle_trace.id)
101100
cycle_trace.add_child(stream_trace)
102101

103-
# Clean up orphaned empty tool uses
104-
clean_orphaned_empty_tool_uses(agent.messages)
105-
106102
# Process messages with exponential backoff for throttling
107103
message: Message
108104
stop_reason: StopReason

src/strands/event_loop/message_processor.py

Lines changed: 0 additions & 105 deletions
This file was deleted.

tests/strands/event_loop/test_message_processor.py

Lines changed: 0 additions & 47 deletions
This file was deleted.

0 commit comments

Comments
 (0)