🐛(helm) fix broken worker assignment due to extra space

Remove incorrect whitespace in queue names that prevented Celery
workers from listening to proper queues. Workers were attempting to
connect to non-existent queues, breaking task distribution.

src/backend/core/recording/event/notification.py

@@ -131,8 +131,8 @@ class NotificationService:
         if not owner_access:
             logger.error("No owner found for recording %s", recording.id)
             return False
+
         payload = {
-            "owner_id": str(owner_access.user.id),
             "filename": recording.key,
             "email": owner_access.user.email,
             "sub": owner_access.user.sub,

src/frontend/src/features/rooms/livekit/hooks/useConnectionObserver.ts

@@ -25,18 +25,6 @@ export const useConnectionObserver = () => {
       posthog.capture('reconnect-event')
     }
 
-    const handleReconnected = () => {
-      posthog.capture('reconnected-event')
-    }
-
-    const handleSignalingConnect = () => {
-      posthog.capture('signaling-connect-event')
-    }
-
-    const handleSignalingReconnect = () => {
-      posthog.capture('signaling-reconnect-event')
-    }
-
     const handleDisconnect = (
       disconnectReason: DisconnectReason | undefined
     ) => {
@@ -55,19 +43,13 @@ export const useConnectionObserver = () => {
     }
 
     room.on(RoomEvent.Connected, handleConnection)
-    room.on(RoomEvent.SignalConnected, handleSignalingConnect)
     room.on(RoomEvent.Disconnected, handleDisconnect)
     room.on(RoomEvent.Reconnecting, handleReconnect)
-    room.on(RoomEvent.Reconnected, handleReconnected)
-    room.on(RoomEvent.SignalReconnecting, handleSignalingReconnect)
 
     return () => {
       room.off(RoomEvent.Connected, handleConnection)
-      room.off(RoomEvent.SignalConnected, handleSignalingConnect)
       room.off(RoomEvent.Disconnected, handleDisconnect)
       room.off(RoomEvent.Reconnecting, handleReconnect)
-      room.off(RoomEvent.Reconnected, handleReconnected)
-      room.off(RoomEvent.SignalReconnecting, handleSignalingReconnect)
     }
   }, [room, isAnalyticsEnabled])
 

src/summary/summary/api/route/tasks.py

@@ -18,7 +18,6 @@ settings = get_settings()
 class TaskCreation(BaseModel):
     """Task data."""
 
-    owner_id: str
     filename: str
     email: str
     sub: str
@@ -36,7 +35,6 @@ async def create_task(request: TaskCreation):
     """Create a task."""
     task = process_audio_transcribe_summarize_v2.apply_async(
         args=[
-            request.owner_id,
             request.filename,
             request.email,
             request.sub,

src/summary/summary/core/celery_worker.py

@@ -204,7 +204,6 @@ def task_failure_handler(task_id, exception=None, **kwargs):
 )
 def process_audio_transcribe_summarize_v2(
     self,
-    owner_id: str,
     filename: str,
     email: str,
     sub: str,
@@ -321,7 +320,7 @@ def process_audio_transcribe_summarize_v2(
     metadata_manager.capture(task_id, settings.posthog_event_success)
 
     if (
-        analytics.is_feature_enabled("summary-enabled", distinct_id=owner_id)
+        analytics.is_feature_enabled("summary-enabled", distinct_id=sub)
         and settings.is_summary_enabled
     ):
         logger.info("Queuing summary generation task.")