From 0f083ab0411576c67c41db558f69120c90b4d6a8 Mon Sep 17 00:00:00 2001 From: Ubuntu Date: Fri, 4 Jul 2025 06:14:26 +0000 Subject: [PATCH] fix requirement bug, fix server.py bug --- .../workshops/python-server/requirements.txt | 2 +- speech-to-speech/workshops/python-server/server.py | 9 ++++++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/speech-to-speech/workshops/python-server/requirements.txt b/speech-to-speech/workshops/python-server/requirements.txt index b1bea717..25446256 100644 --- a/speech-to-speech/workshops/python-server/requirements.txt +++ b/speech-to-speech/workshops/python-server/requirements.txt @@ -6,4 +6,4 @@ websockets==15.0.1 aws_sdk_bedrock_runtime mcp==1.8.1 strands-agents -requests=2.32.3 \ No newline at end of file +requests==2.32.3 \ No newline at end of file diff --git a/speech-to-speech/workshops/python-server/server.py b/speech-to-speech/workshops/python-server/server.py index fd0487a7..78034159 100644 --- a/speech-to-speech/workshops/python-server/server.py +++ b/speech-to-speech/workshops/python-server/server.py @@ -101,6 +101,8 @@ async def websocket_handler(websocket): if not aws_region: aws_region = "us-east-1" + event_type = None + forward_task = None stream_manager = None try: async for message in websocket: @@ -158,7 +160,8 @@ async def websocket_handler(websocket): finally: # Clean up await stream_manager.close() - forward_task.cancel() + if forward_task: + forward_task.cancel() if websocket: websocket.close() if MCP_CLIENT: @@ -248,8 +251,8 @@ async def main(host, port, health_port, enable_mcp=False, enable_strands_agent=F if not host or not port: print(f"HOST and PORT are required. Received HOST: {host}, PORT: {port}") - elif not aws_key_id or not aws_secret: - print(f"AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY are required.") + # elif not aws_key_id or not aws_secret: + # print(f"AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY are required.") else: try: asyncio.run(main(host, port, health_port, enable_mcp, enable_strands))