adsist-cms/python-detector-worker
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

dev-check-cpu #15

Merged
chawanwit.p merged 4 commits from dev-check-cpu into dev 2025-09-25 15:16:45 +00:00
Conversation 0 Commits 4 Files changed 5 +5 -2
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit f9a67935d6 - Show all commits

7
core/streaming/manager.py
View file

@ -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