Skip to content

Commit 812b1d3

Browse files
authored
models - bedrock - remove signaling (#429)
1 parent 6b358fe commit 812b1d3

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

src/strands/models/bedrock.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
import json
88
import logging
99
import os
10-
import threading
1110
from typing import Any, AsyncGenerator, Callable, Iterable, Literal, Optional, Type, TypeVar, Union
1211

1312
import boto3
@@ -335,12 +334,8 @@ def callback(event: Optional[StreamEvent] = None) -> None:
335334
if event is None:
336335
return
337336

338-
signal.wait()
339-
signal.clear()
340-
341337
loop = asyncio.get_event_loop()
342338
queue: asyncio.Queue[Optional[StreamEvent]] = asyncio.Queue()
343-
signal = threading.Event()
344339

345340
thread = asyncio.to_thread(self._stream, callback, messages, tool_specs, system_prompt)
346341
task = asyncio.create_task(thread)
@@ -351,7 +346,6 @@ def callback(event: Optional[StreamEvent] = None) -> None:
351346
break
352347

353348
yield event
354-
signal.set()
355349

356350
await task
357351

0 commit comments

Comments
 (0)