Spaces:
Paused
Paused
Update stt/stt_lifecycle_manager.py
Browse files- stt/stt_lifecycle_manager.py +0 -24
stt/stt_lifecycle_manager.py
CHANGED
|
@@ -49,7 +49,6 @@ class STTLifecycleManager:
|
|
| 49 |
self.event_bus.subscribe(EventType.STT_STARTED, self._handle_stt_start)
|
| 50 |
self.event_bus.subscribe(EventType.STT_STOPPED, self._handle_stt_stop)
|
| 51 |
self.event_bus.subscribe(EventType.AUDIO_CHUNK_RECEIVED, self._handle_audio_chunk)
|
| 52 |
-
self.event_bus.subscribe(EventType.SESSION_STARTED, self._handle_session_started)
|
| 53 |
self.event_bus.subscribe(EventType.SESSION_ENDED, self._handle_session_ended)
|
| 54 |
|
| 55 |
def _setup_resource_pool(self):
|
|
@@ -282,29 +281,6 @@ class STTLifecycleManager:
|
|
| 282 |
error_message=str(e)
|
| 283 |
)
|
| 284 |
|
| 285 |
-
async def _handle_session_started(self, event: Event):
|
| 286 |
-
"""Initialize LLM for session at start"""
|
| 287 |
-
session_id = event.session_id
|
| 288 |
-
|
| 289 |
-
try:
|
| 290 |
-
# Create LLM instance when session starts
|
| 291 |
-
resource_id = f"llm_{session_id}"
|
| 292 |
-
llm_instance = await self.resource_manager.acquire(
|
| 293 |
-
resource_id=resource_id,
|
| 294 |
-
session_id=session_id,
|
| 295 |
-
resource_type=ResourceType.LLM_CONTEXT,
|
| 296 |
-
cleanup_callback=self._cleanup_llm_instance
|
| 297 |
-
)
|
| 298 |
-
|
| 299 |
-
# Create session
|
| 300 |
-
llm_session = LLMSession(session_id, llm_instance)
|
| 301 |
-
self.llm_sessions[session_id] = llm_session
|
| 302 |
-
|
| 303 |
-
log_info(f"✅ LLM initialized for session", session_id=session_id)
|
| 304 |
-
|
| 305 |
-
except Exception as e:
|
| 306 |
-
log_error(f"❌ Failed to initialize LLM", session_id=session_id, error=str(e))
|
| 307 |
-
|
| 308 |
async def _handle_session_ended(self, event: Event):
|
| 309 |
"""Clean up STT resources when session ends"""
|
| 310 |
session_id = event.session_id
|
|
|
|
| 49 |
self.event_bus.subscribe(EventType.STT_STARTED, self._handle_stt_start)
|
| 50 |
self.event_bus.subscribe(EventType.STT_STOPPED, self._handle_stt_stop)
|
| 51 |
self.event_bus.subscribe(EventType.AUDIO_CHUNK_RECEIVED, self._handle_audio_chunk)
|
|
|
|
| 52 |
self.event_bus.subscribe(EventType.SESSION_ENDED, self._handle_session_ended)
|
| 53 |
|
| 54 |
def _setup_resource_pool(self):
|
|
|
|
| 281 |
error_message=str(e)
|
| 282 |
)
|
| 283 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 284 |
async def _handle_session_ended(self, event: Event):
|
| 285 |
"""Clean up STT resources when session ends"""
|
| 286 |
session_id = event.session_id
|