From 8c55135c24d86e26bbc8bf517b2a8110693cf3ac Mon Sep 17 00:00:00 2001 From: Patrick Gray Date: Sat, 12 Jul 2025 02:35:07 +0000 Subject: [PATCH] models - bedrock - remove signaling --- src/strands/models/bedrock.py | 6 ------ 1 file changed, 6 deletions(-) diff --git a/src/strands/models/bedrock.py b/src/strands/models/bedrock.py index fd9adadbc..1463b280b 100644 --- a/src/strands/models/bedrock.py +++ b/src/strands/models/bedrock.py @@ -7,7 +7,6 @@ import json import logging import os -import threading from typing import Any, AsyncGenerator, Callable, Iterable, Literal, Optional, Type, TypeVar, Union import boto3 @@ -335,12 +334,8 @@ def callback(event: Optional[StreamEvent] = None) -> None: if event is None: return - signal.wait() - signal.clear() - loop = asyncio.get_event_loop() queue: asyncio.Queue[Optional[StreamEvent]] = asyncio.Queue() - signal = threading.Event() thread = asyncio.to_thread(self._stream, callback, messages, tool_specs, system_prompt) task = asyncio.create_task(thread) @@ -351,7 +346,6 @@ def callback(event: Optional[StreamEvent] = None) -> None: break yield event - signal.set() await task