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

fix: initialization None error #13

Merged
chawanwit.p merged 1 commit from dev into main 2025-09-24 20:21:40 +00:00
Conversation 0 Commits 1 Files changed 1 +7 -3
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
core/streaming/manager.py
View file

@ -458,11 +458,15 @@ class StreamManager:
# Global shared instance for application use # Global shared instance for application use
# Will be initialized with config value in app.py # Default initialization, will be updated with config value in app.py
shared_stream_manager = None shared_stream_manager = StreamManager(max_streams=20)
def initialize_stream_manager(max_streams: int = 10): def initialize_stream_manager(max_streams: int = 10):
"""Initialize the global stream manager with config value.""" """Re-initialize the global stream manager with config value."""
global shared_stream_manager global shared_stream_manager
# Release old manager if exists
if shared_stream_manager:
# Stop all existing streams gracefully
shared_stream_manager.cleanup()
shared_stream_manager = StreamManager(max_streams=max_streams) shared_stream_manager = StreamManager(max_streams=max_streams)
return shared_stream_manager return shared_stream_manager