From f4b898ccd19c7cf5db9a9d1eba46df2b1e98865e Mon Sep 17 00:00:00 2001 From: ziesorx Date: Thu, 25 Sep 2025 03:27:33 +0700 Subject: [PATCH] fix: wrong function name --- core/streaming/manager.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/core/streaming/manager.py b/core/streaming/manager.py index 0856635..7bd44c1 100644 --- a/core/streaming/manager.py +++ b/core/streaming/manager.py @@ -466,7 +466,10 @@ def initialize_stream_manager(max_streams: int = 10): global shared_stream_manager # Release old manager if exists if shared_stream_manager: - # Stop all existing streams gracefully - shared_stream_manager.cleanup() + try: + # Stop all existing streams gracefully + shared_stream_manager.stop_all() + except Exception as e: + logger.warning(f"Error stopping previous stream manager: {e}") shared_stream_manager = StreamManager(max_streams=max_streams) return shared_stream_manager \ No newline at end of file