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