🐛(summary) fix feature flag on summary job

Sadly, we used user db id as the posthog distinct id of identified user, and not the sub. Before this commit, we were only passing sub to the summary microservice. Add the owner's id. Please note we introduce a different naming behavir, by prefixing the id with "owner". We didn't for the sub and the email. We cannot align sub and email with this new naming approach, because external contributors have already started building their own microservice.
📈(frontend) track more room events in PostHog for disconnections
2025-09-30 15:20:58 +02:00 · 2025-09-18 23:47:13 +02:00 · 2025-09-18 18:27:10 +02:00 · 2025-09-18 18:27:10 +02:00 · 2025-09-18 18:27:10 +02:00 · 2025-09-18 18:27:10 +02:00
42 changed files with 1019 additions and 346 deletions
@@ -45,6 +45,7 @@ COMPOSE_RUN         = $(COMPOSE) run --rm
 COMPOSE_RUN_APP     = $(COMPOSE_RUN) app-dev
 COMPOSE_RUN_CROWDIN = $(COMPOSE_RUN) crowdin crowdin
 WAIT_DB             = @$(COMPOSE_RUN) dockerize -wait tcp://$(DB_HOST):$(DB_PORT) -timeout 60s
+WAIT_MINIO          = @$(COMPOSE_RUN) dockerize -wait tcp://minio:9000 -timeout 60s

 # -- Backend
 MANAGE              = $(COMPOSE_RUN_APP) python manage.py
@@ -53,6 +54,21 @@ MAIL_NPM            = $(COMPOSE_RUN) -w /app/src/mail node npm
 # -- Frontend
 PATH_FRONT          = ./src/frontend

+# -- MinIO / Webhook
+MINIO_ALIAS         ?= meet
+MINIO_ENDPOINT      ?= http://127.0.0.1:9000
+MINIO_ACCESS_KEY    ?= meet
+MINIO_SECRET_KEY    ?= password
+MINIO_BUCKET        ?= meet-media-storage
+MINIO_WEBHOOK_NAME  ?= recording
+
+MINIO_WEBHOOK_ENDPOINT ?= http://app-dev:8000/api/v1.0/recordings/storage-hook/
+
+MINIO_QUEUE_DIR     ?= /data/minio/events
+MINIO_QUEUE_LIMIT   ?= 100000
+
+STORAGE_EVENT_TOKEN ?= password
+
 # ==============================================================================
 # RULES

@@ -71,7 +87,8 @@ create-env-files: \
 	env.d/development/common \
 	env.d/development/crowdin \
 	env.d/development/postgresql \
-	env.d/development/kc_postgresql
+	env.d/development/kc_postgresql \
+	env.d/development/summary
 .PHONY: create-env-files

 bootstrap: ## Prepare Docker images for the project
@@ -116,9 +133,15 @@ run-backend: ## start only the backend application and all needed services
 	@$(WAIT_DB)
 .PHONY: run-backend

+run-summary: ## start only the summary application and all needed services
+	@$(COMPOSE) up --force-recreate -d celery-summary-transcribe
+	@$(COMPOSE) up --force-recreate -d celery-summary-summarize
+.PHONY: run-summary
+
 run:
 run: ## start the wsgi (production) and development server
 	@$(MAKE) run-backend
+	@$(MAKE) run-summary
 	@$(COMPOSE) up --force-recreate -d frontend
 .PHONY: run

@@ -130,6 +153,55 @@ stop: ## stop the development server using Docker
 	@$(COMPOSE) stop
 .PHONY: stop

+# -- MinIO webhook (configuration & events)
+minio-wait: ## wait for minio to be ready
+	@echo "$(BOLD)Waiting for MinIO$(RESET)"
+	$(WAIT_MINIO)
+.PHONY: minio-wait
+
+minio-queue-dir: minio-wait ## ensure queue dir exists in MinIO container
+	@echo "$(BOLD)Ensuring MinIO queue dir$(RESET)"
+	@$(COMPOSE) exec minio sh -lc 'mkdir -p $(MINIO_QUEUE_DIR) && chmod -R 777 $(dir $(MINIO_QUEUE_DIR)) || true'
+.PHONY: minio-queue-dir
+
+minio-alias: minio-wait ## set mc alias to MinIO
+	@echo "$(BOLD)Setting mc alias $(MINIO_ALIAS) -> $(MINIO_ENDPOINT)$(RESET)"
+	@mc alias set $(MINIO_ALIAS) $(MINIO_ENDPOINT) $(MINIO_ACCESS_KEY) $(MINIO_SECRET_KEY) >/dev/null
+.PHONY: minio-alias
+
+minio-webhook-config: minio-alias minio-queue-dir ## configure webhook on MinIO
+	@echo "$(BOLD)Configuring MinIO webhook $(MINIO_WEBHOOK_NAME)$(RESET)"
+	@mc admin config set $(MINIO_ALIAS) notify_webhook:$(MINIO_WEBHOOK_NAME) \
+	  endpoint="$(MINIO_WEBHOOK_ENDPOINT)" \
+	  auth_token="Bearer $(STORAGE_EVENT_TOKEN)" \
+	  queue_dir="$(MINIO_QUEUE_DIR)" \
+	  queue_limit="$(MINIO_QUEUE_LIMIT)"
+.PHONY: minio-webhook-config
+
+minio-restart: minio-alias ## restart MinIO after config change
+	@echo "$(BOLD)Restarting MinIO service$(RESET)"
+	@mc admin service restart $(MINIO_ALIAS)
+.PHONY: minio-restart
+
+minio-events-reset: minio-alias ## remove all bucket notifications
+	@echo "$(BOLD)Removing existing bucket events on $(MINIO_BUCKET)$(RESET)"
+	@mc event remove --force $(MINIO_ALIAS)/$(MINIO_BUCKET) >/dev/null || true
+.PHONY: minio-events-reset
+
+minio-event-add: minio-alias ## add put event -> webhook
+	@echo "$(BOLD)Adding put event -> webhook $(MINIO_WEBHOOK_NAME)$(RESET)"
+	@mc event add $(MINIO_ALIAS)/$(MINIO_BUCKET) arn:minio:sqs::$(MINIO_WEBHOOK_NAME):webhook --event put
+	@mc event list $(MINIO_ALIAS)/$(MINIO_BUCKET)
+.PHONY: minio-event-add
+
+minio-webhook-setup: ## full setup: alias, config, restart, reset events, add event
+minio-webhook-setup: \
+	minio-webhook-config \
+	minio-restart \
+	minio-events-reset \
+	minio-event-add
+.PHONY: minio-webhook-setup
+
 # -- Front

 frontend-development-install: ## install the frontend locally
@@ -246,6 +318,9 @@ env.d/development/postgresql:
 env.d/development/kc_postgresql:
 	cp -n env.d/development/kc_postgresql.dist env.d/development/kc_postgresql

+env.d/development/summary:
+	cp -n env.d/development/summary.dist env.d/development/summary
+
 # -- Internationalization

 env.d/development/crowdin:
@@ -221,3 +221,64 @@ services:
        - ./docker/livekit/out:/out
      depends_on:
        - redis
+
+  redis-summary:
+    image: redis
+    ports:
+      - "6379:6379"
+
+  app-summary-dev:
+    build:
+      context: src/summary
+      target: development
+      args:
+        DOCKER_USER: ${DOCKER_USER:-1000}
+    user: ${DOCKER_USER:-1000}
+    env_file:
+      - env.d/development/summary
+    ports:
+      - "8001:8000"
+    volumes:
+      - ./src/summary:/app
+    depends_on:
+        - redis-summary
+
+  celery-summary-transcribe:
+    container_name: celery-summary-transcribe
+    build:
+      context: ./src/summary
+      dockerfile: Dockerfile
+      target: production
+    command: celery -A summary.core.celery_worker worker --pool=solo --loglevel=debug -Q transcribe-queue
+    env_file:
+      - env.d/development/summary
+    volumes:
+      - ./src/summary:/app
+    depends_on:
+      - redis-summary
+      - app-summary-dev
+      - minio
+    develop:
+      watch:
+        - action: rebuild
+          path: ./src/summary
+
+  celery-summary-summarize:
+    container_name: celery-summary-summarize
+    build:
+      context: ./src/summary
+      dockerfile: Dockerfile
+      target: production
+    command: celery -A summary.core.celery_worker worker --pool=solo --loglevel=debug -Q summarize-queue
+    env_file:
+      - env.d/development/summary
+    volumes:
+      - ./src/summary:/app
+    depends_on:
+      - redis-summary
+      - app-summary-dev
+      - minio
+    develop:
+      watch:
+        - action: rebuild
+          path: ./src/summary
@@ -53,6 +53,11 @@ LIVEKIT_VERIFY_SSL=False
 ALLOW_UNREGISTERED_ROOMS=False

 # Recording
+RECORDING_ENABLE=True
+RECORDING_STORAGE_EVENT_ENABLE=True
+RECORDING_STORAGE_EVENT_TOKEN=password
+SUMMARY_SERVICE_ENDPOINT=http://app-summary-dev:8000/api/v1/tasks/
+SUMMARY_SERVICE_API_TOKEN=password
 SCREEN_RECORDING_BASE_URL=http://localhost:3000/recordings

 # Telephony
@@ -0,0 +1,23 @@
+APP_NAME="meet-app-summary-dev"
+APP_API_TOKEN="password"
+
+AWS_STORAGE_BUCKET_NAME="meet-media-storage"
+AWS_S3_ENDPOINT_URL="minio:9000"
+AWS_S3_SECURE_ACCESS=false
+
+AWS_S3_ACCESS_KEY_ID="meet"
+AWS_S3_SECRET_ACCESS_KEY="password"
+
+WHISPERX_BASE_URL="https://configure-your-url.com"
+WHISPERX_ASR_MODEL="large-v2"
+WHISPERX_API_KEY="your-secret-key"
+
+LLM_BASE_URL="https://configure-your-url.com"
+LLM_API_KEY="dev-apikey"
+LLM_MODEL="Qwen/Qwen2.5-Coder-32B-Instruct-AWQ"
+
+WEBHOOK_API_TOKEN="secret"
+WEBHOOK_URL="https://configure-your-url.com"
+
+POSTHOG_API_KEY="your-posthog-key"
+POSTHOG_ENABLED="False"
@@ -1,7 +1,7 @@

 [project]
 name = "agents"
-version = "0.1.35"
+version = "0.1.38"
 requires-python = ">=3.12"
 dependencies = [
    "livekit-agents==1.2.6",
@@ -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,
@@ -7,7 +7,7 @@ build-backend = "setuptools.build_meta"

 [project]
 name = "meet"
-version = "0.1.35"
+version = "0.1.38"
 authors = [{ "name" = "DINUM", "email" = "dev@mail.numerique.gouv.fr" }]
 classifiers = [
    "Development Status :: 5 - Production/Stable",
@@ -38,7 +38,7 @@ dependencies = [
    "django-redis==6.0.0",
    "django-storages[s3]==1.14.6",
    "django-timezone-field>=5.1",
-    "django==5.2.3",
+    "django==5.2.6",
    "djangorestframework==3.16.0",
    "drf_spectacular==0.28.0",
    "dockerflow==2024.4.2",
@@ -1,16 +1,16 @@
 {
  "name": "meet",
-  "version": "0.1.35",
+  "version": "0.1.38",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "meet",
-      "version": "0.1.35",
+      "version": "0.1.38",
      "dependencies": {
        "@livekit/components-react": "2.9.13",
        "@livekit/components-styles": "1.1.6",
-        "@livekit/track-processors": "0.6.0",
+        "@livekit/track-processors": "0.6.1",
        "@pandacss/preset-panda": "0.54.0",
        "@react-aria/toast": "3.0.5",
        "@react-types/overlays": "3.9.0",
@@ -26,7 +26,7 @@
        "i18next-parser": "9.3.0",
        "i18next-resources-to-backend": "1.2.1",
        "libphonenumber-js": "1.12.10",
-        "livekit-client": "2.15.5",
+        "livekit-client": "2.15.7",
        "posthog-js": "1.256.2",
        "react": "18.3.1",
        "react-aria-components": "1.10.1",
@@ -1281,9 +1281,9 @@
      }
    },
    "node_modules/@livekit/track-processors": {
-      "version": "0.6.0",
-      "resolved": "https://registry.npmjs.org/@livekit/track-processors/-/track-processors-0.6.0.tgz",
-      "integrity": "sha512-h0Ewdp2/u44QnfLsmhL/IBCkFJsl10eyodErOedP9yWTS4c8m8ibqBWaNH0bHDeqg4Ue+OzzUb7dogUb2nJ0Ow==",
+      "version": "0.6.1",
+      "resolved": "https://registry.npmjs.org/@livekit/track-processors/-/track-processors-0.6.1.tgz",
+      "integrity": "sha512-t9JMDvMUlaaURDDRZFQEkRYR4q2qROPOOIs3aZXQVL6v/QYgJ0tPg/QfbvHC8b6mYPwcaJgVz3KTk5XQ07fEMg==",
      "license": "Apache-2.0",
      "dependencies": {
        "@mediapipe/tasks-vision": "0.10.14"
@@ -7460,9 +7460,9 @@
      }
    },
    "node_modules/livekit-client": {
-      "version": "2.15.5",
-      "resolved": "https://registry.npmjs.org/livekit-client/-/livekit-client-2.15.5.tgz",
-      "integrity": "sha512-zn36akmDlqZxlrTOUgYXtxtj35HQ44aJ+mgKat9BTSPiZru4RjEHOtp8RJE6jGoN2miJlWiOeEKHB2+ae3YrSw==",
+      "version": "2.15.7",
+      "resolved": "https://registry.npmjs.org/livekit-client/-/livekit-client-2.15.7.tgz",
+      "integrity": "sha512-19m8Q1cvRl5PslRawDUgWXeP8vL8584tX8kiZEJaPZo83U/L6VPS/O7pP06phfJaBWeeV8sAOVtEPlQiZEHtpg==",
      "license": "Apache-2.0",
      "dependencies": {
        "@livekit/mutex": "1.1.1",
@@ -1,7 +1,7 @@
 {
  "name": "meet",
  "private": true,
-  "version": "0.1.35",
+  "version": "0.1.38",
  "type": "module",
  "scripts": {
    "dev": "panda codegen && vite",
@@ -15,7 +15,7 @@
  "dependencies": {
    "@livekit/components-react": "2.9.13",
    "@livekit/components-styles": "1.1.6",
-    "@livekit/track-processors": "0.6.0",
+    "@livekit/track-processors": "0.6.1",
    "@pandacss/preset-panda": "0.54.0",
    "@react-aria/toast": "3.0.5",
    "@react-types/overlays": "3.9.0",
@@ -31,7 +31,7 @@
    "i18next-parser": "9.3.0",
    "i18next-resources-to-backend": "1.2.1",
    "libphonenumber-js": "1.12.10",
-    "livekit-client": "2.15.5",
+    "livekit-client": "2.15.7",
    "posthog-js": "1.256.2",
    "react": "18.3.1",
    "react-aria-components": "1.10.1",
@@ -10,8 +10,6 @@ import {
  MediaDeviceFailure,
  Room,
  RoomOptions,
-  supportsAdaptiveStream,
-  supportsDynacast,
  VideoPresets,
 } from 'livekit-client'
 import { keys } from '@/api/queryKeys'
@@ -87,13 +85,10 @@ export const Conference = ({
    retry: false,
  })

-  const isAdaptiveStreamSupported = supportsAdaptiveStream()
-  const isDynacastSupported = supportsDynacast()
-
  const roomOptions = useMemo((): RoomOptions => {
    return {
-      adaptiveStream: isAdaptiveStreamSupported,
-      dynacast: isDynacastSupported,
+      adaptiveStream: true,
+      dynacast: true,
      publishDefaults: {
        videoCodec: 'vp9',
      },
@@ -116,8 +111,6 @@ export const Conference = ({
    userConfig.videoPublishResolution,
    userConfig.audioDeviceId,
    userConfig.audioOutputDeviceId,
-    isAdaptiveStreamSupported,
-    isDynacastSupported,
  ])

  const room = useMemo(() => new Room(roomOptions), [roomOptions])
@@ -638,7 +638,7 @@ export const Join = ({
                      <Button
                        size="sm"
                        variant="tertiary"
-                        onPress={openPermissionsDialog}
+                        onPress={() => openPermissionsDialog('videoinput')}
                      >
                        {t(`permissionsButton.${permissionsButtonLabel}`)}
                      </Button>
@@ -37,6 +37,22 @@ export const Permissions = () => {
    injectIconIntoTranslation(t('body.openMenu.others'))

  useEffect(() => {
+    if (
+      permissions.isPermissionDialogOpen &&
+      permissions.isMicrophoneGranted &&
+      permissions.requestOrigin == 'audioinput'
+    ) {
+      closePermissionsDialog()
+    }
+
+    if (
+      permissions.isPermissionDialogOpen &&
+      permissions.isCameraGranted &&
+      permissions.requestOrigin == 'videoinput'
+    ) {
+      closePermissionsDialog()
+    }
+
    if (
      permissions.isPermissionDialogOpen &&
      permissions.isCameraGranted &&
@@ -64,13 +80,17 @@ export const Permissions = () => {
          display: 'flex',
          justifyContent: 'center',
          alignItems: 'center',
+          flexDirection: 'column',
+          md: {
+            flexDirection: 'row',
+          },
        })}
      >
        <img
          src="/assets/camera_mic_permission.svg"
          alt=""
          className={css({
-            minWidth: '290px',
+            width: '100%',
            minHeight: '290px',
            maxWidth: '290px',
          })}
@@ -15,6 +15,7 @@ import { SettingsButton } from './SettingsButton'
 import { SettingsDialogExtendedKey } from '@/features/settings/type'
 import { TrackSource } from '@livekit/protocol'
 import Source = Track.Source
+import { isSafari } from '@/utils/livekit'

 type AudioDevicesControlProps = Omit<
  UseTrackToggleProps<Source.Microphone>,
@@ -111,19 +112,21 @@ export const AudioDevicesControl = ({
                  onSubmit={saveAudioInputDeviceId}
                />
              </div>
-              <div
-                style={{
-                  flex: '1 1 0',
-                  minWidth: 0,
-                }}
-              >
-                <SelectDevice
-                  context="room"
-                  kind="audiooutput"
-                  id={audioOutputDeviceId}
-                  onSubmit={saveAudioOutputDeviceId}
-                />
-              </div>
+              {!isSafari() && (
+                <div
+                  style={{
+                    flex: '1 1 0',
+                    minWidth: 0,
+                  }}
+                >
+                  <SelectDevice
+                    context="room"
+                    kind="audiooutput"
+                    id={audioOutputDeviceId}
+                    onSubmit={saveAudioOutputDeviceId}
+                  />
+                </div>
+              )}
              <SettingsButton
                settingTab={SettingsDialogExtendedKey.AUDIO}
                onPress={close}
@@ -19,7 +19,7 @@ export const PermissionNeededButton = () => {
      <Button
        aria-label={t('ariaLabel')}
        tooltip={t('tooltip')}
-        onPress={openPermissionsDialog}
+        onPress={() => openPermissionsDialog()}
        variant="permission"
      >
        <div
@@ -107,9 +107,7 @@ export const ToggleDevice = <T extends ToggleSource>({
  }, [enabled, kind, deviceShortcut, t])

  const Icon =
-    isDisabled || cannotUseDevice || !enabled
-      ? deviceIcons.toggleOff
-      : deviceIcons.toggleOn
+    isDisabled || !enabled ? deviceIcons.toggleOff : deviceIcons.toggleOn

  const roomContext = useMaybeRoomContext()
  if (kind === 'audioinput' && pushToTalk && roomContext) {
@@ -126,7 +124,12 @@ export const ToggleDevice = <T extends ToggleSource>({
          isDisabled || cannotUseDevice || !enabled ? errorVariant : variant
        }
        shySelected
-        onPress={() => (cannotUseDevice ? openPermissionsDialog() : toggle())}
+        onPress={() => {
+          if (cannotUseDevice) {
+            openPermissionsDialog(kind)
+          }
+          toggle()
+        }}
        aria-label={toggleLabel}
        tooltip={
          cannotUseDevice
@@ -6,7 +6,7 @@ import { useTranslation } from 'react-i18next'
 import { Avatar } from '@/components/Avatar'
 import { getParticipantColor } from '@/features/rooms/utils/getParticipantColor'
 import { getParticipantIsRoomAdmin } from '@/features/rooms/utils/getParticipantIsRoomAdmin'
-import { Participant, Track } from 'livekit-client'
+import { LocalParticipant, Participant, Track } from 'livekit-client'
 import { isLocal } from '@/utils/livekit'
 import {
  useIsSpeaking,
@@ -54,9 +54,11 @@ const MicIndicator = ({ participant }: MicIndicatorProps) => {
        tooltip={label}
        aria-label={label}
        isDisabled={isMuted || !canMute}
-        onPress={() =>
+        onPress={async () =>
          !isMuted && isLocal(participant)
-            ? muteParticipant(participant)
+            ? await (participant as LocalParticipant)?.setMicrophoneEnabled(
+                false
+              )
            : setIsAlertOpen(true)
        }
        data-attr="participants-mute"
@@ -40,6 +40,7 @@ export const ScreenShareToggle = ({
      isDisabled={!canShareScreen}
      square
      variant={variant}
+      aria-label={t(tooltipLabel)}
      tooltip={t(tooltipLabel)}
      onPress={(e) => {
        buttonProps.onClick?.(
@@ -25,6 +25,18 @@ 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
    ) => {
@@ -43,13 +55,19 @@ 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])

@@ -63,11 +63,13 @@ export function MobileControlBar({
            onDeviceError={(error) =>
              onDeviceError?.({ source: Track.Source.Microphone, error })
            }
+            hideMenu={true}
          />
          <VideoDeviceControl
            onDeviceError={(error) =>
              onDeviceError?.({ source: Track.Source.Camera, error })
            }
+            hideMenu={true}
          />
          <HandToggle />
          <Button
@@ -13,6 +13,7 @@ type BaseState = {
  microphonePermission: PermissionState
  isLoading: boolean
  isPermissionDialogOpen: boolean
+  requestOrigin?: 'audioinput' | 'videoinput'
 }

 type DerivedState = {
@@ -31,6 +32,7 @@ export const permissionsStore = proxy<BaseState>({
  microphonePermission: undefined,
  isLoading: true,
  isPermissionDialogOpen: false,
+  requestOrigin: undefined,
 }) as State

 derive(
@@ -52,8 +54,11 @@ derive(
  }
 )

-export const openPermissionsDialog = () => {
+export const openPermissionsDialog = (
+  requestOrigin?: 'audioinput' | 'videoinput'
+) => {
  permissionsStore.isPermissionDialogOpen = true
+  permissionsStore.requestOrigin = requestOrigin
 }

 export const closePermissionsDialog = () => {
@@ -144,11 +144,13 @@ summary:
    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
    AWS_S3_ACCESS_KEY_ID: meet
    AWS_S3_SECRET_ACCESS_KEY: password
-    OPENAI_API_KEY: password
-    OPENAI_BASE_URL: https://albertine.beta.numerique.gouv.fr/v1
-    OPENAI_ASR_MODEL: large-v2
-    OPENAI_LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    WEBHOOK_API_TOKEN: password
    WEBHOOK_URL: https://www.mock-impress.com/webhook/
    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
@@ -168,7 +170,7 @@ summary:
    - "8000"
    - "--reload"

-celery:
+celeryTranscribe:
  replicas: 1
  envVars:
    APP_NAME: summary-microservice
@@ -177,16 +179,19 @@ celery:
    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
    AWS_S3_ACCESS_KEY_ID: meet
    AWS_S3_SECRET_ACCESS_KEY: password
-    OPENAI_API_KEY: password
-    OPENAI_BASE_URL: https://albertine.beta.numerique.gouv.fr/v1
-    OPENAI_ASR_MODEL: large-v2
-    OPENAI_LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    WEBHOOK_API_TOKEN: password
    WEBHOOK_URL: https://www.mock-impress.com/webhook/
    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
    CELERY_RESULT_BACKEND: redis://default:pass@redis-master:6379/1
-  
+    TASK_TRACKER_REDIS_URL: redis://default:pass@redis-master:6379/1
+
  image:
    repository: localhost:5001/meet-summary
    pullPolicy: Always
@@ -199,6 +204,43 @@ celery:
    - "worker"
    - "--pool=solo"
    - "--loglevel=info"
+    - "-Q transcribe-queue"
+
+celerySummarize:
+  replicas: 1
+  envVars:
+    APP_NAME: summary-microservice
+    APP_API_TOKEN: password
+    AWS_STORAGE_BUCKET_NAME: meet-media-storage
+    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
+    AWS_S3_ACCESS_KEY_ID: meet
+    AWS_S3_SECRET_ACCESS_KEY: password
+    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
+    WEBHOOK_API_TOKEN: password
+    WEBHOOK_URL: https://www.mock-impress.com/webhook/
+    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
+    CELERY_RESULT_BACKEND: redis://default:pass@redis-master:6379/1
+    TASK_TRACKER_REDIS_URL: redis://default:pass@redis-master:6379/1
+
+  image:
+    repository: localhost:5001/meet-summary
+    pullPolicy: Always
+    tag: "latest"
+
+  command:
+    - "celery"
+    - "-A"
+    - "summary.core.celery_worker"
+    - "worker"
+    - "--pool=solo"
+    - "--loglevel=info"
+    - "-Q summarize-queue"

 ingressMedia:
  enabled: true
@@ -151,11 +151,13 @@ summary:
    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
    AWS_S3_ACCESS_KEY_ID: meet
    AWS_S3_SECRET_ACCESS_KEY: password
-    OPENAI_API_KEY: password
-    OPENAI_BASE_URL: https://albertine.beta.numerique.gouv.fr/v1
-    OPENAI_ASR_MODEL: large-v2
-    OPENAI_LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    WEBHOOK_API_TOKEN: password
    WEBHOOK_URL: https://www.mock-impress.com/webhook/
    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
@@ -176,7 +178,7 @@ summary:
    - "8000"
    - "--reload"

-celery:
+celeryTranscribe:
  replicas: 1
  envVars:
    APP_NAME: summary-microservice
@@ -185,11 +187,13 @@ celery:
    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
    AWS_S3_ACCESS_KEY_ID: meet
    AWS_S3_SECRET_ACCESS_KEY: password
-    OPENAI_API_KEY: password
-    OPENAI_BASE_URL: https://albertine.beta.numerique.gouv.fr/v1
-    OPENAI_ASR_MODEL: large-v2
-    OPENAI_LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    WEBHOOK_API_TOKEN: password
    WEBHOOK_URL: https://www.mock-impress.com/webhook/
    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
@@ -208,6 +212,45 @@ celery:
    - "worker"
    - "--pool=solo"
    - "--loglevel=info"
+    - "-Q"
+    - "transcribe-queue"
+
+celerySummarize:
+  replicas: 1
+  envVars:
+    APP_NAME: summary-microservice
+    APP_API_TOKEN: password
+    AWS_STORAGE_BUCKET_NAME: meet-media-storage
+    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
+    AWS_S3_ACCESS_KEY_ID: meet
+    AWS_S3_SECRET_ACCESS_KEY: password
+    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
+    WEBHOOK_API_TOKEN: password
+    WEBHOOK_URL: https://www.mock-impress.com/webhook/
+    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
+    CELERY_RESULT_BACKEND: redis://default:pass@redis-master:6379/1
+    TASK_TRACKER_REDIS_URL: redis://default:pass@redis-master:6379/1
+
+  image:
+    repository: localhost:5001/meet-summary
+    pullPolicy: Always
+    tag: "latest"
+
+  command:
+    - "celery"
+    - "-A"
+    - "summary.core.celery_worker"
+    - "worker"
+    - "--pool=solo"
+    - "--loglevel=info"
+    - "-Q"
+    - "summarize-queue"

 agents:
  replicas: 1
@@ -171,11 +171,13 @@ summary:
    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
    AWS_S3_ACCESS_KEY_ID: meet
    AWS_S3_SECRET_ACCESS_KEY: password
-    OPENAI_API_KEY: password
-    OPENAI_BASE_URL: https://albertine.beta.numerique.gouv.fr/v1
-    OPENAI_ASR_MODEL: openai/whisper-large-v3
-    OPENAI_LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    WEBHOOK_API_TOKEN: password
    WEBHOOK_URL: https://www.mock-impress.com/webhook/
    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
@@ -195,7 +197,7 @@ summary:
    - "8000"
    - "--reload"

-celery:
+celeryTranscribe:
  replicas: 1
  envVars:
    APP_NAME: summary-microservice
@@ -204,15 +206,18 @@ celery:
    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
    AWS_S3_ACCESS_KEY_ID: meet
    AWS_S3_SECRET_ACCESS_KEY: password
-    OPENAI_API_KEY: password
-    OPENAI_BASE_URL: https://albertine.beta.numerique.gouv.fr/v1
-    OPENAI_ASR_MODEL: openai/whisper-large-v3
-    OPENAI_LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
    WEBHOOK_API_TOKEN: password
    WEBHOOK_URL: https://www.mock-impress.com/webhook/
    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
    CELERY_RESULT_BACKEND: redis://default:pass@redis-master:6379/1
+    TASK_TRACKER_REDIS_URL: redis://default:pass@redis-master:6379/1

  image:
    repository: localhost:5001/meet-summary
@@ -226,6 +231,43 @@ celery:
    - "worker"
    - "--pool=solo"
    - "--loglevel=info"
+    - "-Q transcribe-queue"
+
+celerySummarize:
+  replicas: 1
+  envVars:
+    APP_NAME: summary-microservice
+    APP_API_TOKEN: password
+    AWS_STORAGE_BUCKET_NAME: meet-media-storage
+    AWS_S3_ENDPOINT_URL: minio.meet.svc.cluster.local:9000
+    AWS_S3_ACCESS_KEY_ID: meet
+    AWS_S3_SECRET_ACCESS_KEY: password
+    AWS_S3_SECURE_ACCESS: False
+    WHISPERX_API_KEY: your-secret-value
+    WHISPERX_BASE_URL: https://configure-your-url.com
+    WHISPERX_ASR_MODEL: large-v2
+    LLM_BASE_URL: https://configure-your-url.com
+    LLM_API_KEY: your-secret-value
+    LLM_MODEL: meta-llama/Llama-3.1-8B-Instruct
+    WEBHOOK_API_TOKEN: password
+    WEBHOOK_URL: https://www.mock-impress.com/webhook/
+    CELERY_BROKER_URL: redis://default:pass@redis-master:6379/1
+    CELERY_RESULT_BACKEND: redis://default:pass@redis-master:6379/1
+    TASK_TRACKER_REDIS_URL: redis://default:pass@redis-master:6379/1
+
+  image:
+    repository: localhost:5001/meet-summary
+    pullPolicy: Always
+    tag: "latest"
+
+  command:
+    - "celery"
+    - "-A"
+    - "summary.core.celery_worker"
+    - "worker"
+    - "--pool=solo"
+    - "--loglevel=info"
+    - "-Q summarize-queue"

 ingressMedia:
  enabled: true
@@ -82,9 +82,15 @@ spec:
        volumeMounts:
        - mountPath: /data
          name: data
+        - mountPath: /etc/ssl/certs/mkcert-ca.pem
+          name: mkcert
+          subPath: rootCA.pem
      volumes:
      - name: data
        emptyDir:
+      - name: mkcert
+        secret:
+          secretName: mkcert
 ---
 apiVersion: batch/v1
 kind: Job
@@ -105,3 +111,26 @@ spec:
            exit 0
      restartPolicy: Never
  backoffLimit: 1
+---
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: minio-webhook
+spec:
+  template:
+    spec:
+      containers:
+      - name: mc
+        image: minio/mc
+        command:
+          - /bin/sh
+          - -c
+          - |
+            /usr/bin/mc alias set meet http://minio:9000 meet password && \
+            /usr/bin/mc admin config set meet notify_webhook:meet-webhook endpoint="https://meet.127.0.0.1.nip.io/api/v1.0/recordings/storage-hook/" auth_token="Bearer password" && \
+            /usr/bin/mc admin service restart meet --wait --json && \
+            sleep 15 && \
+            /usr/bin/mc event add meet/meet-media-storage arn:minio:sqs::meet-webhook:webhook --event put && \
+            exit 0
+      restartPolicy: Never
+  backoffLimit: 1
@@ -1,4 +1,4 @@
 apiVersion: v2
 type: application
 name: meet
-version: 0.0.11
+version: 0.0.12
@@ -176,12 +176,21 @@ Requires top level scope
 {{- end }}

 {{/*
-Full name for the Celery
+Full name for the Celery Transcribe

 Requires top level scope
 */}}
-{{- define "meet.celery.fullname" -}}
-{{ include "meet.fullname" . }}-celery
+{{- define "meet.celeryTranscribe.fullname" -}}
+{{ include "meet.fullname" . }}-celery-transcribe
+{{- end }}
+
+{{/*
+Full name for the Celery Summarize
+
+Requires top level scope
+*/}}
+{{- define "meet.celerySummarize.fullname" -}}
+{{ include "meet.fullname" . }}-celery-summarize
 {{- end }}

 {{/*
@@ -1,26 +1,26 @@
-{{- $envVars := include "meet.common.env" (list . .Values.celery) -}}
-{{- $fullName := include "meet.celery.fullname" . -}}
-{{- $component := "celery" -}}
+{{- $envVars := include "meet.common.env" (list . .Values.celerySummarize) -}}
+{{- $fullName := include "meet.celerySummarize.fullname" . -}}
+{{- $component := "celery-summarize" -}}
 apiVersion: apps/v1
 kind: Deployment
 metadata:
  name: {{ $fullName }}
  annotations:
-   {{- with .Values.celery.dpAnnotations }}
+   {{- with .Values.celerySummarize.dpAnnotations }}
   {{- toYaml . | nindent 4 }}
   {{- end }}
  namespace: {{ .Release.Namespace | quote }}
  labels:
    {{- include "meet.common.labels" (list . $component) | nindent 4 }}
 spec:
-  replicas: {{ .Values.celery.replicas }}
+  replicas: {{ .Values.celerySummarize.replicas }}
  selector:
    matchLabels:
      {{- include "meet.common.selectorLabels" (list . $component) | nindent 6 }}
  template:
    metadata:
      annotations:
-        {{- with .Values.celery.podAnnotations }}
+        {{- with .Values.celerySummarize.podAnnotations }}
        {{- toYaml . | nindent 8 }}
        {{- end }}
      labels:
@@ -30,19 +30,19 @@ spec:
      imagePullSecrets:
        - name: {{ include "meet.secret.dockerconfigjson.name" (dict "fullname" (include "meet.fullname" .) "imageCredentials" $.Values.image.credentials) }}
      {{- end }}
-      shareProcessNamespace: {{ .Values.celery.shareProcessNamespace }}
+      shareProcessNamespace: {{ .Values.celerySummarize.shareProcessNamespace }}
      containers:
-        {{- with .Values.celery.sidecars }}
+        {{- with .Values.celerySummarize.sidecars }}
          {{- toYaml . | nindent 8 }}
        {{- end }}
        - name: {{ .Chart.Name }}
-          image: "{{ (.Values.celery.image | default dict).repository | default .Values.image.repository }}:{{ (.Values.celery.image | default dict).tag | default .Values.image.tag }}"
-          imagePullPolicy: {{ (.Values.celery.image | default dict).pullPolicy | default .Values.image.pullPolicy }}
-          {{- with .Values.celery.command }}
+          image: "{{ (.Values.celerySummarize.image | default dict).repository | default .Values.image.repository }}:{{ (.Values.celerySummarize.image | default dict).tag | default .Values.image.tag }}"
+          imagePullPolicy: {{ (.Values.celerySummarize.image | default dict).pullPolicy | default .Values.image.pullPolicy }}
+          {{- with .Values.celerySummarize.command }}
          command:
            {{- toYaml . | nindent 12 }}
          {{- end }}
-          {{- with .Values.celery.args }}
+          {{- with .Values.celerySummarize.args }}
          args:
            {{- toYaml . | nindent 12 }}
          {{- end }}
@@ -50,27 +50,27 @@ spec:
            {{- if $envVars }}
            {{- $envVars | indent 12 }}
            {{- end }}
-          {{- with .Values.celery.securityContext }}
+          {{- with .Values.celerySummarize.securityContext }}
          securityContext:
            {{- toYaml . | nindent 12 }}
          {{- end }}
          ports:
            - name: http
-              containerPort: {{ .Values.celery.service.targetPort }}
+              containerPort: {{ .Values.celerySummarize.service.targetPort }}
              protocol: TCP
-          {{- if .Values.celery.probes.liveness }}
+          {{- if .Values.celerySummarize.probes.liveness }}
          livenessProbe:
-            {{- include "meet.probes.abstract" (merge .Values.celery.probes.liveness (dict "targetPort" .Values.celery.service.targetPort )) | nindent 12 }}
+            {{- include "meet.probes.abstract" (merge .Values.celerySummarize.probes.liveness (dict "targetPort" .Values.celerySummarize.service.targetPort )) | nindent 12 }}
          {{- end }}
-          {{- if .Values.celery.probes.readiness }}
+          {{- if .Values.celerySummarize.probes.readiness }}
          readinessProbe:
-            {{- include "meet.probes.abstract" (merge .Values.celery.probes.readiness (dict "targetPort" .Values.celery.service.targetPort )) | nindent 12 }}
+            {{- include "meet.probes.abstract" (merge .Values.celerySummarize.probes.readiness (dict "targetPort" .Values.celerySummarize.service.targetPort )) | nindent 12 }}
          {{- end }}
-          {{- if .Values.celery.probes.startup }}
+          {{- if .Values.celerySummarize.probes.startup }}
          startupProbe:
-            {{- include "meet.probes.abstract" (merge .Values.celery.probes.startup (dict "targetPort" .Values.celery.service.targetPort )) | nindent 12 }}
+            {{- include "meet.probes.abstract" (merge .Values.celerySummarize.probes.startup (dict "targetPort" .Values.celerySummarize.service.targetPort )) | nindent 12 }}
          {{- end }}
-          {{- with .Values.celery.resources }}
+          {{- with .Values.celerySummarize.resources }}
          resources:
            {{- toYaml . | nindent 12 }}
          {{- end }}
@@ -80,25 +80,25 @@ spec:
              mountPath: {{ $value.path }}
              subPath: content
            {{- end }}
-            {{- range $name, $volume := .Values.celery.persistence }}
+            {{- range $name, $volume := .Values.celerySummarize.persistence }}
            - name: "{{ $name }}"
              mountPath: "{{ $volume.mountPath }}"
            {{- end }}
-            {{- range .Values.celery.extraVolumeMounts }}
+            {{- range .Values.celerySummarize.extraVolumeMounts }}
            - name: {{ .name }}
              mountPath: {{ .mountPath }}
              subPath: {{ .subPath | default "" }}
              readOnly: {{ .readOnly }}
            {{- end }}
-      {{- with .Values.celery.nodeSelector }}
+      {{- with .Values.celerySummarize.nodeSelector }}
      nodeSelector:
        {{- toYaml . | nindent 8 }}
      {{- end }}
-      {{- with .Values.celery.affinity }}
+      {{- with .Values.celerySummarize.affinity }}
      affinity:
        {{- toYaml . | nindent 8 }}
      {{- end }}
-      {{- with .Values.celery.tolerations }}
+      {{- with .Values.celerySummarize.tolerations }}
      tolerations:
        {{- toYaml . | nindent 8 }}
      {{- end }}
@@ -108,7 +108,7 @@ spec:
          configMap:
            name: "{{ include "meet.fullname" $ }}-files-{{ $index }}"
        {{- end }}
-        {{- range $name, $volume := .Values.celery.persistence }}
+        {{- range $name, $volume := .Values.celerySummarize.persistence }}
        - name: "{{ $name }}"
          {{- if eq $volume.type "emptyDir" }}
          emptyDir: {}
@@ -117,7 +117,7 @@ spec:
            claimName: "{{ $fullName }}-{{ $name }}"
          {{- end }}
        {{- end }}
-        {{- range .Values.celery.extraVolumes }}
+        {{- range .Values.celerySummarize.extraVolumes }}
        - name: {{ .name }}
          {{- if .existingClaim }}
          persistentVolumeClaim:
@@ -139,7 +139,7 @@ spec:
          {{- end }}
        {{- end }}
 ---
-{{ if .Values.celery.pdb.enabled }}
+{{ if .Values.celerySummarize.pdb.enabled }}
 apiVersion: policy/v1
 kind: PodDisruptionBudget
 metadata:
@@ -0,0 +1,153 @@
+{{- $envVars := include "meet.common.env" (list . .Values.celeryTranscribe) -}}
+{{- $fullName := include "meet.celeryTranscribe.fullname" . -}}
+{{- $component := "celery-transcribe" -}}
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: {{ $fullName }}
+  annotations:
+   {{- with .Values.celeryTranscribe.dpAnnotations }}
+   {{- toYaml . | nindent 4 }}
+   {{- end }}
+  namespace: {{ .Release.Namespace | quote }}
+  labels:
+    {{- include "meet.common.labels" (list . $component) | nindent 4 }}
+spec:
+  replicas: {{ .Values.celeryTranscribe.replicas }}
+  selector:
+    matchLabels:
+      {{- include "meet.common.selectorLabels" (list . $component) | nindent 6 }}
+  template:
+    metadata:
+      annotations:
+        {{- with .Values.celeryTranscribe.podAnnotations }}
+        {{- toYaml . | nindent 8 }}
+        {{- end }}
+      labels:
+        {{- include "meet.common.selectorLabels" (list . $component) | nindent 8 }}
+    spec:
+      {{- if $.Values.image.credentials }}
+      imagePullSecrets:
+        - name: {{ include "meet.secret.dockerconfigjson.name" (dict "fullname" (include "meet.fullname" .) "imageCredentials" $.Values.image.credentials) }}
+      {{- end }}
+      shareProcessNamespace: {{ .Values.celeryTranscribe.shareProcessNamespace }}
+      containers:
+        {{- with .Values.celeryTranscribe.sidecars }}
+          {{- toYaml . | nindent 8 }}
+        {{- end }}
+        - name: {{ .Chart.Name }}
+          image: "{{ (.Values.celeryTranscribe.image | default dict).repository | default .Values.image.repository }}:{{ (.Values.celeryTranscribe.image | default dict).tag | default .Values.image.tag }}"
+          imagePullPolicy: {{ (.Values.celeryTranscribe.image | default dict).pullPolicy | default .Values.image.pullPolicy }}
+          {{- with .Values.celeryTranscribe.command }}
+          command:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          {{- with .Values.celeryTranscribe.args }}
+          args:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          env:
+            {{- if $envVars }}
+            {{- $envVars | indent 12 }}
+            {{- end }}
+          {{- with .Values.celeryTranscribe.securityContext }}
+          securityContext:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          ports:
+            - name: http
+              containerPort: {{ .Values.celeryTranscribe.service.targetPort }}
+              protocol: TCP
+          {{- if .Values.celeryTranscribe.probes.liveness }}
+          livenessProbe:
+            {{- include "meet.probes.abstract" (merge .Values.celeryTranscribe.probes.liveness (dict "targetPort" .Values.celeryTranscribe.service.targetPort )) | nindent 12 }}
+          {{- end }}
+          {{- if .Values.celeryTranscribe.probes.readiness }}
+          readinessProbe:
+            {{- include "meet.probes.abstract" (merge .Values.celeryTranscribe.probes.readiness (dict "targetPort" .Values.celeryTranscribe.service.targetPort )) | nindent 12 }}
+          {{- end }}
+          {{- if .Values.celeryTranscribe.probes.startup }}
+          startupProbe:
+            {{- include "meet.probes.abstract" (merge .Values.celeryTranscribe.probes.startup (dict "targetPort" .Values.celeryTranscribe.service.targetPort )) | nindent 12 }}
+          {{- end }}
+          {{- with .Values.celeryTranscribe.resources }}
+          resources:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          volumeMounts:
+            {{- range $index, $value := .Values.mountFiles }}
+            - name: "files-{{ $index }}"
+              mountPath: {{ $value.path }}
+              subPath: content
+            {{- end }}
+            {{- range $name, $volume := .Values.celeryTranscribe.persistence }}
+            - name: "{{ $name }}"
+              mountPath: "{{ $volume.mountPath }}"
+            {{- end }}
+            {{- range .Values.celeryTranscribe.extraVolumeMounts }}
+            - name: {{ .name }}
+              mountPath: {{ .mountPath }}
+              subPath: {{ .subPath | default "" }}
+              readOnly: {{ .readOnly }}
+            {{- end }}
+      {{- with .Values.celeryTranscribe.nodeSelector }}
+      nodeSelector:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      {{- with .Values.celeryTranscribe.affinity }}
+      affinity:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      {{- with .Values.celeryTranscribe.tolerations }}
+      tolerations:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      volumes:
+        {{- range $index, $value := .Values.mountFiles }}
+        - name: "files-{{ $index }}"
+          configMap:
+            name: "{{ include "meet.fullname" $ }}-files-{{ $index }}"
+        {{- end }}
+        {{- range $name, $volume := .Values.celeryTranscribe.persistence }}
+        - name: "{{ $name }}"
+          {{- if eq $volume.type "emptyDir" }}
+          emptyDir: {}
+          {{- else }}
+          persistentVolumeClaim:
+            claimName: "{{ $fullName }}-{{ $name }}"
+          {{- end }}
+        {{- end }}
+        {{- range .Values.celeryTranscribe.extraVolumes }}
+        - name: {{ .name }}
+          {{- if .existingClaim }}
+          persistentVolumeClaim:
+            claimName: {{ .existingClaim }}
+          {{- else if .hostPath }}
+          hostPath:
+            {{ toYaml .hostPath | nindent 12 }}
+          {{- else if .csi }}
+          csi:
+            {{- toYaml .csi | nindent 12 }}
+          {{- else if .configMap }}
+          configMap:
+            {{- toYaml .configMap | nindent 12 }}
+          {{- else if .emptyDir }}
+          emptyDir:
+            {{- toYaml .emptyDir | nindent 12 }}
+          {{- else }}
+          emptyDir: {}
+          {{- end }}
+        {{- end }}
+---
+{{ if .Values.celeryTranscribe.pdb.enabled }}
+apiVersion: policy/v1
+kind: PodDisruptionBudget
+metadata:
+  name: {{ $fullName }}
+  namespace: {{ .Release.Namespace | quote }}
+spec:
+  maxUnavailable: 1
+  selector:
+    matchLabels:
+      {{- include "meet.common.selectorLabels" (list . $component) | nindent 6 }}
+{{ end }}
@@ -524,96 +524,189 @@ summary:
  pdb:
    enabled: true

-## @section celery
+## @section celeryTranscribe

-celery:
-  ## @param celery.dpAnnotations Annotations to add to the celery Deployment
+celeryTranscribe:
+  ## @param celeryTranscribe.dpAnnotations Annotations to add to the celeryTranscribe Deployment
  dpAnnotations: {}

-  ## @param celery.command Override the celery container command
+  ## @param celeryTranscribe.command Override the celeryTranscribe container command
  command: []

-  ## @param celery.args Override the celery container args
+  ## @param celeryTranscribe.args Override the celeryTranscribe container args
  args: []

-  ## @param celery.replicas Amount of celery replicas
+  ## @param celeryTranscribe.replicas Amount of celeryTranscribe replicas
  replicas: 1

-  ## @param celery.shareProcessNamespace Enable share process namespace between containers
+  ## @param celeryTranscribe.shareProcessNamespace Enable share process namespace between containers
  shareProcessNamespace: false

-  ## @param celery.sidecars Add sidecars containers to celery deployment
+  ## @param celeryTranscribe.sidecars Add sidecars containers to celeryTranscribe deployment
  sidecars: []

-  ## @param celery.migrateJobAnnotations Annotations for the migrate job
+  ## @param celeryTranscribe.migrateJobAnnotations Annotations for the migrate job
  migrateJobAnnotations: {}

-  ## @param celery.securityContext Configure celery Pod security context
+  ## @param celeryTranscribe.securityContext Configure celeryTranscribe Pod security context
  securityContext: null

-  ## @param celery.envVars Configure celery container environment variables
-  ## @extra celery.envVars.BY_VALUE Example environment variable by setting value directly
-  ## @extra celery.envVars.FROM_CONFIGMAP.configMapKeyRef.name Name of a ConfigMap when configuring env vars from a ConfigMap
-  ## @extra celery.envVars.FROM_CONFIGMAP.configMapKeyRef.key Key within a ConfigMap when configuring env vars from a ConfigMap
-  ## @extra celery.envVars.FROM_SECRET.secretKeyRef.name Name of a Secret when configuring env vars from a Secret
-  ## @extra celery.envVars.FROM_SECRET.secretKeyRef.key Key within a Secret when configuring env vars from a Secret
-  ## @skip celery.envVars
+  ## @param celeryTranscribe.envVars Configure celeryTranscribe container environment variables
+  ## @extra celeryTranscribe.envVars.BY_VALUE Example environment variable by setting value directly
+  ## @extra celeryTranscribe.envVars.FROM_CONFIGMAP.configMapKeyRef.name Name of a ConfigMap when configuring env vars from a ConfigMap
+  ## @extra celeryTranscribe.envVars.FROM_CONFIGMAP.configMapKeyRef.key Key within a ConfigMap when configuring env vars from a ConfigMap
+  ## @extra celeryTranscribe.envVars.FROM_SECRET.secretKeyRef.name Name of a Secret when configuring env vars from a Secret
+  ## @extra celeryTranscribe.envVars.FROM_SECRET.secretKeyRef.key Key within a Secret when configuring env vars from a Secret
+  ## @skip celeryTranscribe.envVars
  envVars:
    <<: *commonEnvVars

-  ## @param celery.podAnnotations Annotations to add to the celery Pod
+  ## @param celeryTranscribe.podAnnotations Annotations to add to the celeryTranscribe Pod
  podAnnotations: {}

-  ## @param celery.service.type celery Service type
-  ## @param celery.service.port celery Service listening port
-  ## @param celery.service.targetPort celery container listening port
-  ## @param celery.service.annotations Annotations to add to the celery Service
+  ## @param celeryTranscribe.service.type celeryTranscribe Service type
+  ## @param celeryTranscribe.service.port celeryTranscribe Service listening port
+  ## @param celeryTranscribe.service.targetPort celeryTranscribe container listening port
+  ## @param celeryTranscribe.service.annotations Annotations to add to the celeryTranscribe Service
  service:
    type: ClusterIP
    port: 80
    targetPort: 8000
    annotations: {}

-  ## @param celery.probes Configure celery probes
-  ## @param celery.probes.liveness.path [nullable] Configure path for celery HTTP liveness probe
-  ## @param celery.probes.liveness.targetPort [nullable] Configure port for celery HTTP liveness probe
-  ## @param celery.probes.liveness.initialDelaySeconds [nullable] Configure initial delay for celery liveness probe
-  ## @param celery.probes.liveness.initialDelaySeconds [nullable] Configure timeout for celery liveness probe
-  ## @param celery.probes.startup.path [nullable] Configure path for celery HTTP startup probe
-  ## @param celery.probes.startup.targetPort [nullable] Configure port for celery HTTP startup probe
-  ## @param celery.probes.startup.initialDelaySeconds [nullable] Configure initial delay for celery startup probe
-  ## @param celery.probes.startup.initialDelaySeconds [nullable] Configure timeout for celery startup probe
-  ## @param celery.probes.readiness.path [nullable] Configure path for celery HTTP readiness probe
-  ## @param celery.probes.readiness.targetPort [nullable] Configure port for celery HTTP readiness probe
-  ## @param celery.probes.readiness.initialDelaySeconds [nullable] Configure initial delay for celery readiness probe
-  ## @param celery.probes.readiness.initialDelaySeconds [nullable] Configure timeout for celery readiness probe
+  ## @param celeryTranscribe.probes Configure celeryTranscribe probes
+  ## @param celeryTranscribe.probes.liveness.path [nullable] Configure path for celeryTranscribe HTTP liveness probe
+  ## @param celeryTranscribe.probes.liveness.targetPort [nullable] Configure port for celeryTranscribe HTTP liveness probe
+  ## @param celeryTranscribe.probes.liveness.initialDelaySeconds [nullable] Configure initial delay for celeryTranscribe liveness probe
+  ## @param celeryTranscribe.probes.liveness.initialDelaySeconds [nullable] Configure timeout for celeryTranscribe liveness probe
+  ## @param celeryTranscribe.probes.startup.path [nullable] Configure path for celeryTranscribe HTTP startup probe
+  ## @param celeryTranscribe.probes.startup.targetPort [nullable] Configure port for celeryTranscribe HTTP startup probe
+  ## @param celeryTranscribe.probes.startup.initialDelaySeconds [nullable] Configure initial delay for celeryTranscribe startup probe
+  ## @param celeryTranscribe.probes.startup.initialDelaySeconds [nullable] Configure timeout for celeryTranscribe startup probe
+  ## @param celeryTranscribe.probes.readiness.path [nullable] Configure path for celeryTranscribe HTTP readiness probe
+  ## @param celeryTranscribe.probes.readiness.targetPort [nullable] Configure port for celeryTranscribe HTTP readiness probe
+  ## @param celeryTranscribe.probes.readiness.initialDelaySeconds [nullable] Configure initial delay for celeryTranscribe readiness probe
+  ## @param celeryTranscribe.probes.readiness.initialDelaySeconds [nullable] Configure timeout for celeryTranscribe readiness probe
  probes: {}

-  ## @param celery.resources Resource requirements for the celery container
+  ## @param celeryTranscribe.resources Resource requirements for the celeryTranscribe container
  resources: {}

-  ## @param celery.nodeSelector Node selector for the celery Pod
+  ## @param celeryTranscribe.nodeSelector Node selector for the celeryTranscribe Pod
  nodeSelector: {}

-  ## @param celery.tolerations Tolerations for the celery Pod
+  ## @param celeryTranscribe.tolerations Tolerations for the celeryTranscribe Pod
  tolerations: []

-  ## @param celery.affinity Affinity for the celery Pod
+  ## @param celeryTranscribe.affinity Affinity for the celeryTranscribe Pod
  affinity: {}

-  ## @param celery.persistence Additional volumes to create and mount on the celery. Used for debugging purposes
-  ## @extra celery.persistence.volume-name.size Size of the additional volume
-  ## @extra celery.persistence.volume-name.type Type of the additional volume, persistentVolumeClaim or emptyDir
-  ## @extra celery.persistence.volume-name.mountPath Path where the volume should be mounted to
+  ## @param celeryTranscribe.persistence Additional volumes to create and mount on the celeryTranscribe. Used for debugging purposes
+  ## @extra celeryTranscribe.persistence.volume-name.size Size of the additional volume
+  ## @extra celeryTranscribe.persistence.volume-name.type Type of the additional volume, persistentVolumeClaim or emptyDir
+  ## @extra celeryTranscribe.persistence.volume-name.mountPath Path where the volume should be mounted to
  persistence: {}

-  ## @param celery.extraVolumeMounts Additional volumes to mount on the celery.
+  ## @param celeryTranscribe.extraVolumeMounts Additional volumes to mount on the celeryTranscribe.
  extraVolumeMounts: []

-  ## @param celery.extraVolumes Additional volumes to mount on the celery.
+  ## @param celeryTranscribe.extraVolumes Additional volumes to mount on the celeryTranscribe.
  extraVolumes: []

-  ## @param celery.pdb.enabled Enable pdb on celery
+  ## @param celeryTranscribe.pdb.enabled Enable pdb on celeryTranscribe
+  pdb:
+    enabled: false
+
+## @section celerySummarize
+
+celerySummarize:
+  ## @param celerySummarize.dpAnnotations Annotations to add to the celerySummarize Deployment
+  dpAnnotations: {}
+
+  ## @param celerySummarize.command Override the celerySummarize container command
+  command: []
+
+  ## @param celerySummarize.args Override the celerySummarize container args
+  args: []
+
+  ## @param celerySummarize.replicas Amount of celerySummarize replicas
+  replicas: 1
+
+  ## @param celerySummarize.shareProcessNamespace Enable share process namespace between containers
+  shareProcessNamespace: false
+
+  ## @param celerySummarize.sidecars Add sidecars containers to celerySummarize deployment
+  sidecars: []
+
+  ## @param celerySummarize.migrateJobAnnotations Annotations for the migrate job
+  migrateJobAnnotations: {}
+
+  ## @param celerySummarize.securityContext Configure celerySummarize Pod security context
+  securityContext: null
+
+  ## @param celerySummarize.envVars Configure celerySummarize container environment variables
+  ## @extra celerySummarize.envVars.BY_VALUE Example environment variable by setting value directly
+  ## @extra celerySummarize.envVars.FROM_CONFIGMAP.configMapKeyRef.name Name of a ConfigMap when configuring env vars from a ConfigMap
+  ## @extra celerySummarize.envVars.FROM_CONFIGMAP.configMapKeyRef.key Key within a ConfigMap when configuring env vars from a ConfigMap
+  ## @extra celerySummarize.envVars.FROM_SECRET.secretKeyRef.name Name of a Secret when configuring env vars from a Secret
+  ## @extra celerySummarize.envVars.FROM_SECRET.secretKeyRef.key Key within a Secret when configuring env vars from a Secret
+  ## @skip celerySummarize.envVars
+  envVars:
+    <<: *commonEnvVars
+
+  ## @param celerySummarize.podAnnotations Annotations to add to the celerySummarize Pod
+  podAnnotations: {}
+
+  ## @param celerySummarize.service.type celerySummarize Service type
+  ## @param celerySummarize.service.port celerySummarize Service listening port
+  ## @param celerySummarize.service.targetPort celerySummarize container listening port
+  ## @param celerySummarize.service.annotations Annotations to add to the celerySummarize Service
+  service:
+    type: ClusterIP
+    port: 80
+    targetPort: 8000
+    annotations: {}
+
+  ## @param celerySummarize.probes Configure celerySummarize probes
+  ## @param celerySummarize.probes.liveness.path [nullable] Configure path for celerySummarize HTTP liveness probe
+  ## @param celerySummarize.probes.liveness.targetPort [nullable] Configure port for celerySummarize HTTP liveness probe
+  ## @param celerySummarize.probes.liveness.initialDelaySeconds [nullable] Configure initial delay for celerySummarize liveness probe
+  ## @param celerySummarize.probes.liveness.initialDelaySeconds [nullable] Configure timeout for celerySummarize liveness probe
+  ## @param celerySummarize.probes.startup.path [nullable] Configure path for celerySummarize HTTP startup probe
+  ## @param celerySummarize.probes.startup.targetPort [nullable] Configure port for celerySummarize HTTP startup probe
+  ## @param celerySummarize.probes.startup.initialDelaySeconds [nullable] Configure initial delay for celerySummarize startup probe
+  ## @param celerySummarize.probes.startup.initialDelaySeconds [nullable] Configure timeout for celerySummarize startup probe
+  ## @param celerySummarize.probes.readiness.path [nullable] Configure path for celerySummarize HTTP readiness probe
+  ## @param celerySummarize.probes.readiness.targetPort [nullable] Configure port for celerySummarize HTTP readiness probe
+  ## @param celerySummarize.probes.readiness.initialDelaySeconds [nullable] Configure initial delay for celerySummarize readiness probe
+  ## @param celerySummarize.probes.readiness.initialDelaySeconds [nullable] Configure timeout for celerySummarize readiness probe
+  probes: {}
+
+  ## @param celerySummarize.resources Resource requirements for the celerySummarize container
+  resources: {}
+
+  ## @param celerySummarize.nodeSelector Node selector for the celerySummarize Pod
+  nodeSelector: {}
+
+  ## @param celerySummarize.tolerations Tolerations for the celerySummarize Pod
+  tolerations: []
+
+  ## @param celerySummarize.affinity Affinity for the celerySummarize Pod
+  affinity: {}
+
+  ## @param celerySummarize.persistence Additional volumes to create and mount on the celerySummarize. Used for debugging purposes
+  ## @extra celerySummarize.persistence.volume-name.size Size of the additional volume
+  ## @extra celerySummarize.persistence.volume-name.type Type of the additional volume, persistentVolumeClaim or emptyDir
+  ## @extra celerySummarize.persistence.volume-name.mountPath Path where the volume should be mounted to
+  persistence: {}
+
+  ## @param celerySummarize.extraVolumeMounts Additional volumes to mount on the celerySummarize.
+  extraVolumeMounts: []
+
+  ## @param celerySummarize.extraVolumes Additional volumes to mount on the celerySummarize.
+  extraVolumes: []
+
+  ## @param celerySummarize.pdb.enabled Enable pdb on celerySummarize
  pdb:
    enabled: false

@@ -1,12 +1,12 @@
 {
  "name": "mail_mjml",
-  "version": "0.1.35",
+  "version": "0.1.38",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "mail_mjml",
-      "version": "0.1.35",
+      "version": "0.1.38",
      "license": "MIT",
      "dependencies": {
        "@html-to/text-cli": "0.5.4",
@@ -1,6 +1,6 @@
 {
  "name": "mail_mjml",
-  "version": "0.1.35",
+  "version": "0.1.38",
  "description": "An util to generate html and text django's templates from mjml templates",
  "type": "module",
  "dependencies": {
@@ -1,12 +1,12 @@
 {
  "name": "sdk",
-  "version": "0.1.35",
+  "version": "0.1.38",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "sdk",
-      "version": "0.1.35",
+      "version": "0.1.38",
      "license": "ISC",
      "workspaces": [
        "./library",
@@ -1,6 +1,6 @@
 {
  "name": "sdk",
-  "version": "0.1.35",
+  "version": "0.1.38",
  "author": "",
  "license": "ISC",
  "description": "",
@@ -8,6 +8,14 @@ COPY pyproject.toml .

 RUN pip3 install --no-cache-dir .

+FROM base AS development
+WORKDIR /app
+
+COPY . .
+RUN pip3 install --no-cache-dir -e ".[dev]" || pip3 install --no-cache-dir -e .
+
+CMD ["uvicorn", "summary.main:app", "--host", "0.0.0.0", "--port", "8000", "--reload"]
+
 FROM base AS production

 WORKDIR /app
@@ -0,0 +1,32 @@
+# Experimental Stack
+
+This is an experimental part of the stack.  It currently lacks proper observability, unit tests, and other production-grade features. This serves as the base for AI features in Visio.
+
+## Usage
+
+From the root of the project:
+
+```sh
+make bootstrap
+```
+
+Configure your env values in `env.d/summary` to properly set up WhisperX and the LLM API you will call.
+
+```sh
+make run
+```
+
+When the stack is up, configure the MinIO webhook
+*(TODO: add this step to `make bootstrap`)*
+
+```sh
+make minio-webhook-setup
+```
+
+If you want to develop on the Celery workers with hot reloading, run:
+
+```sh
+docker compose watch celery-summary-transcribe celery-summary-summarize
+```
+
+Celery workers will hot reload on any change.
@@ -1,27 +0,0 @@
-services:
-  redis:
-    image: redis
-    ports:
-      - "6379:6379"
-  app:
-    container_name: app
-    build: .
-    command: uvicorn summary.main:app --host 0.0.0.0 --port 8000 --reload
-    volumes:
-      - .:/app
-    ports:
-      - "8000:8000"
-    restart: always
-    env_file:
-      ".env"
-    depends_on:
-      - redis
-  celery_worker:
-    container_name: celery_worker
-    build: .
-    command: celery -A summary.core.celery_worker worker --pool=solo --loglevel=debug
-    volumes:
-      - .:/app
-    depends_on:
-      - redis
-      - app
@@ -1,7 +1,7 @@

 [project]
 name = "summary"
-version = "0.1.35"
+version = "0.1.38"
 dependencies = [
    "fastapi[standard]>=0.105.0",
    "uvicorn>=0.24.0",
@@ -8,14 +8,17 @@ from fastapi import APIRouter
 from pydantic import BaseModel

 from summary.core.celery_worker import (
-    process_audio_transcribe_summarize,
    process_audio_transcribe_summarize_v2,
 )
+from summary.core.config import get_settings
+
+settings = get_settings()


 class TaskCreation(BaseModel):
    """Task data."""

+    owner_id: str
    filename: str
    email: str
    sub: str
@@ -31,22 +34,19 @@ router = APIRouter(prefix="/tasks")
@router.post("/")
 async def create_task(request: TaskCreation):
    """Create a task."""
-    if request.version == 1:
-        task = process_audio_transcribe_summarize.delay(
-            request.filename, request.email, request.sub
-        )
-    else:
-        task = process_audio_transcribe_summarize_v2.apply_async(
-            args=[
-                request.filename,
-                request.email,
-                request.sub,
-                time.time(),
-                request.room,
-                request.recording_date,
-                request.recording_time,
-            ]
-        )
+    task = process_audio_transcribe_summarize_v2.apply_async(
+        args=[
+            request.owner_id,
+            request.filename,
+            request.email,
+            request.sub,
+            time.time(),
+            request.room,
+            request.recording_date,
+            request.recording_time,
+        ],
+        queue=settings.transcribe_queue,
+    )

    return {"id": task.id, "message": "Task created"}

@@ -48,6 +48,17 @@ class Analytics:
        except Exception as e:
            raise AnalyticsException("Failed to capture analytics event") from e

+    def is_feature_enabled(self, feature_name: str, distinct_id: str = None) -> bool:
+        """Check if a feature flag is enabled for a user."""
+        if self.is_disabled:
+            return False
+
+        try:
+            return self._client.feature_enabled(feature_name, distinct_id)
+        except Exception as e:
+            logger.error("Error checking feature flag %s: %s", feature_name, e)
+            return False
+

@lru_cache
 def get_analytics():
@@ -103,7 +114,7 @@ class MetadataManager:

        initial_metadata = {
            "start_time": time.time(),
-            "asr_model": settings.openai_asr_model,
+            "asr_model": settings.whisperx_asr_model,
            "retries": 0,
        }

@@ -21,7 +21,14 @@ from urllib3.util import Retry

 from summary.core.analytics import MetadataManager, get_analytics
 from summary.core.config import get_settings
-from summary.core.prompt import get_instructions
+from summary.core.prompt import (
+    PROMPT_SYSTEM_CLEANING,
+    PROMPT_SYSTEM_NEXT_STEP,
+    PROMPT_SYSTEM_PART,
+    PROMPT_SYSTEM_PLAN,
+    PROMPT_SYSTEM_TLDR,
+    PROMPT_USER_PART,
+)

 settings = get_settings()
 analytics = get_analytics()
@@ -95,6 +102,39 @@ def create_retry_session():
    return session


+class LLMException(Exception):
+    """LLM call failed."""
+
+
+class LLMService:
+    """Service for performing calls to the LLM configured in the settings."""
+
+    def __init__(self):
+        """Init the LLMService once."""
+        self._client = openai.OpenAI(
+            base_url=settings.llm_base_url, api_key=settings.llm_api_key
+        )
+
+    def call(self, system_prompt: str, user_prompt: str):
+        """Call the LLM service.
+
+        Takes a system prompt and a user prompt, and returns the LLM's response
+        Returns None if the call fails.
+        """
+        try:
+            response = self._client.chat.completions.create(
+                model=settings.llm_model,
+                messages=[
+                    {"role": "system", "content": system_prompt},
+                    {"role": "user", "content": user_prompt},
+                ],
+            )
+            return response.choices[0].message.content
+        except Exception as e:
+            logger.error("LLM call failed: %s", e)
+            raise LLMException("LLM call failed.") from e
+
+
 def format_segments(transcription_data):
    """Format transcription segments from WhisperX into a readable conversation format.

@@ -156,89 +196,15 @@ def task_failure_handler(task_id, exception=None, **kwargs):
    metadata_manager.capture(task_id, settings.posthog_event_failure)


-@celery.task(max_retries=settings.celery_max_retries)
-def process_audio_transcribe_summarize(filename: str, email: str, sub: str):
-    """Process an audio file by transcribing it and generating a summary.
-
-    This Celery task performs the following operations:
-    1. Retrieves the audio file from MinIO storage
-    2. Transcribes the audio using OpenAI-compliant API's ASR model
-    3. Generates a summary of the transcription using OpenAI-compliant API's LLM
-    4. Sends the results via webhook
-    """
-    logger.info("Notification received")
-    logger.debug("filename: %s", filename)
-
-    minio_client = Minio(
-        settings.aws_s3_endpoint_url,
-        access_key=settings.aws_s3_access_key_id,
-        secret_key=settings.aws_s3_secret_access_key,
-        secure=settings.aws_s3_secure_access,
-    )
-
-    logger.debug("Connection to the Minio bucket successful")
-
-    audio_file_stream = minio_client.get_object(
-        settings.aws_storage_bucket_name, object_name=filename
-    )
-
-    temp_file_path = save_audio_stream(audio_file_stream)
-    logger.debug("Recording successfully downloaded, filepath: %s", temp_file_path)
-
-    logger.info("Initiating OpenAI client")
-
-    openai_client = openai.OpenAI(
-        api_key=settings.openai_api_key,
-        base_url=settings.openai_base_url,
-        max_retries=settings.openai_max_retries,
-    )
-
-    try:
-        logger.info("Querying transcription …")
-        with open(temp_file_path, "rb") as audio_file:
-            transcription = openai_client.audio.transcriptions.create(
-                model=settings.openai_asr_model, file=audio_file
-            )
-            transcription = transcription.text
-
-            logger.debug("Transcription: \n %s", transcription)
-    finally:
-        if os.path.exists(temp_file_path):
-            os.remove(temp_file_path)
-            logger.debug("Temporary file removed: %s", temp_file_path)
-
-    instructions = get_instructions(transcription)
-    summary_response = openai_client.chat.completions.create(
-        model=settings.openai_llm_model, messages=instructions
-    )
-
-    summary = summary_response.choices[0].message.content
-    logger.debug("Summary: \n %s", summary)
-
-    # fixme - generate a title using LLM
-    data = {
-        "title": "Votre résumé",
-        "content": summary,
-        "email": email,
-        "sub": sub,
-    }
-
-    logger.debug("Submitting webhook to %s", settings.webhook_url)
-    logger.debug("Request payload: %s", json.dumps(data, indent=2))
-
-    response = post_with_retries(settings.webhook_url, data)
-
-    logger.info("Webhook submitted successfully. Status: %s", response.status_code)
-    logger.debug("Response body: %s", response.text)
-
-
@celery.task(
    bind=True,
    autoretry_for=[exceptions.HTTPError],
    max_retries=settings.celery_max_retries,
+    queue=settings.transcribe_queue,
 )
 def process_audio_transcribe_summarize_v2(
    self,
+    owner_id: str,
    filename: str,
    email: str,
    sub: str,
@@ -292,19 +258,19 @@ def process_audio_transcribe_summarize_v2(
        logger.error(error_msg)
        raise AudioValidationError(error_msg)

-    logger.info("Initiating OpenAI client")
-    openai_client = openai.OpenAI(
-        api_key=settings.openai_api_key,
-        base_url=settings.openai_base_url,
-        max_retries=settings.openai_max_retries,
+    logger.info("Initiating WhisperX client")
+    whisperx_client = openai.OpenAI(
+        api_key=settings.whisperx_api_key,
+        base_url=settings.whisperx_base_url,
+        max_retries=settings.whisperx_max_retries,
    )

    try:
        logger.info("Querying transcription …")
        transcription_start_time = time.time()
        with open(temp_file_path, "rb") as audio_file:
-            transcription = openai_client.audio.transcriptions.create(
-                model=settings.openai_asr_model, file=audio_file
+            transcription = whisperx_client.audio.transcriptions.create(
+                model=settings.whisperx_asr_model, file=audio_file
            )
            metadata_manager.track(
                task_id,
@@ -354,4 +320,80 @@ def process_audio_transcribe_summarize_v2(

    metadata_manager.capture(task_id, settings.posthog_event_success)

-    # TODO - integrate summarize the transcript and create a new document.
+    if (
+        analytics.is_feature_enabled("summary-enabled", distinct_id=owner_id)
+        and settings.is_summary_enabled
+    ):
+        logger.info("Queuing summary generation task.")
+        summarize_transcription.apply_async(
+            args=[formatted_transcription, email, sub, title],
+            queue=settings.summarize_queue,
+        )
+    else:
+        logger.info("Summary generation not enabled for this user.")
+
+
+@celery.task(
+    bind=True,
+    autoretry_for=[LLMException, Exception],
+    max_retries=settings.celery_max_retries,
+    queue=settings.summarize_queue,
+)
+def summarize_transcription(self, transcript: str, email: str, sub: str, title: str):
+    """Generate a summary from the provided transcription text.
+
+    This Celery task performs the following operations:
+    1. Uses an LLM to generate a TL;DR summary of the transcription.
+    2. Breaks the transcription into parts and summarizes each part.
+    3. Cleans up the combined summary
+    4. Generates next steps.
+    5. Sends the final summary via webhook.
+    """
+    logger.info("Starting summarization task")
+
+    llm_service = LLMService()
+
+    tldr = llm_service.call(PROMPT_SYSTEM_TLDR, transcript)
+
+    logger.info("TLDR generated")
+
+    parts = llm_service.call(PROMPT_SYSTEM_PLAN, transcript)
+    logger.info("Plan generated")
+
+    parts = parts.split("\n")
+    parts = [x for x in parts if x.strip() != ""]
+    logger.info("Empty parts removed")
+
+    parts_summarized = []
+    for part in parts:
+        prompt_user_part = PROMPT_USER_PART.format(part=part, transcript=transcript)
+        logger.info("Summarizing part: %s", part)
+        parts_summarized.append(llm_service.call(PROMPT_SYSTEM_PART, prompt_user_part))
+
+    logger.info("Parts summarized")
+
+    raw_summary = "\n\n".join(parts_summarized)
+
+    next_steps = llm_service.call(PROMPT_SYSTEM_NEXT_STEP, transcript)
+    logger.info("Next steps generated")
+
+    cleaned_summary = llm_service.call(PROMPT_SYSTEM_CLEANING, raw_summary)
+    logger.info("Summary cleaned")
+
+    summary = tldr + "\n\n" + cleaned_summary + "\n\n" + next_steps
+
+    data = {
+        "title": settings.summary_title_template.format(
+            title=title,
+        ),
+        "content": summary,
+        "email": email,
+        "sub": sub,
+    }
+
+    logger.debug("Submitting webhook to %s", settings.webhook_url)
+
+    response = post_with_retries(settings.webhook_url, data)
+
+    logger.info("Webhook submitted successfully. Status: %s", response.status_code)
+    logger.debug("Response body: %s", response.text)
@@ -24,6 +24,9 @@ class Settings(BaseSettings):
    celery_result_backend: str = "redis://redis/0"
    celery_max_retries: int = 1

+    transcribe_queue: str = "transcribe-queue"
+    summarize_queue: str = "summarize-queue"
+
    # Minio settings
    aws_storage_bucket_name: str
    aws_s3_endpoint_url: str
@@ -32,11 +35,13 @@ class Settings(BaseSettings):
    aws_s3_secure_access: bool = True

    # AI-related settings
-    openai_api_key: str
-    openai_base_url: str = "https://api.openai.com/v1"
-    openai_asr_model: str = "whisper-1"
-    openai_llm_model: str = "gpt-4o"
-    openai_max_retries: int = 0
+    whisperx_api_key: str
+    whisperx_base_url: str = "https://api.openai.com/v1"
+    whisperx_asr_model: str = "whisper-1"
+    whisperx_max_retries: int = 0
+    llm_base_url: str
+    llm_api_key: str
+    llm_model: str

    # Webhook-related settings
    webhook_max_retries: int = 2
@@ -50,6 +55,10 @@ class Settings(BaseSettings):
    document_title_template: Optional[str] = (
        'Réunion "{room}" du {room_recording_date} à {room_recording_time}'
    )
+    summary_title_template: Optional[str] = "Résumé de {title}"
+
+    # Summary related settings
+    is_summary_enabled: bool = True

    # Sentry
    sentry_is_enabled: bool = False
@@ -1,52 +1,28 @@
 # ruff: noqa

+PROMPT_SYSTEM_TLDR = """Tu es un agent dont le rôle est de créer un TL;DR (résumé très concis) d'un compte rendu de réunion. Tu utiliseras un style synthétique, administratif, à la troisième personne, sans affect. Tu recevras en entrée le transcript. Ta tâche est de rédiger un résumé concis et structuré, en te concentrant uniquement sur les informations essentielles et pertinentes. Tu répondras en un paragraphe structuré (3 à 6 phrases), sans rien ajouter d'autre. Tu répondras dans le format suivant sans rien ajouter d'autre:
+### Résumé TL;DR
+[Résumé concis et structuré]"""

-def get_instructions(transcript):
-    """Declare the summarize instructions."""
-    prompt = f"""
-    Audience: Coworkers.
-
-    **Do:**
-    - Detect the language of the transcript and provide your entire response in the same language.
-    - If any part of the transcript is unclear or lacks detail, politely inform the user, specifying which areas need further clarification.
-    - Ensure the accuracy of all information and refrain from adding unverified details.
-    - Format the response using proper markdown and structured sections.
-    - Be concise and avoid repeating yourself between the sections.
-    - Be super precise on nickname
-    - Be a nit-picker
-    - Auto-evaluate your response
-
-    **Don't:**
-    - Write something your are not sure.
-    - Write something that is not mention in the transcript.
-    - Don't make mistake while mentioning someone
-    **Task:**
-    Summarize the provided meeting transcript into clear and well-organized meeting minutes. The summary should be structured into the following sections, excluding irrelevant or inapplicable details:
-
-    1. **Summary**: Write a  TL;DR of the meeting.
-    2. **Subjects Discussed**: List the key points or issues in bullet points.
-    4. **Next Steps**: Provide action items as bullet points, assigning each task to a responsible individual and including deadlines (if mentioned). Format action items as tickable checkboxes. Ensure every action is assigned and, if a deadline is provided, that it is clearly stated.
-
-    **Transcript**:  
-    {transcript}
-
-    **Response:**
-
-    ### Summary [Translate this title based on the transcript’s language]
-    [Provide a brief overview of the key points discussed]
-
-    ### Subjects Discussed [Translate this title based on the transcript’s language]
-    - [Summarize each topic concisely]
-
-    ### Next Steps [Translate this title based on the transcript’s language]  
-    - [ ] Action item [Assign to the responsible individual(s) and include a deadline if applicable, follow this strict format: Action - List of owner(s), deadline.]
+PROMPT_SYSTEM_PLAN = """Ta tâche est de diviser le contenu du transcript en sujets concrets correspondant aux grands axes discutés durant la réunion. Ne crée pas de catégories génériques. Les titres doivent être courts, précis et représentatifs des échanges. Veille à ce que chaque sujet soit distinct et qu’aucun thème ne soit répété. Tu te limiteras à 5 ou 6 sujets maximum.
+L'introduction, ordre du jour, conclusion, etc. seront rajoutés a posteriori. Tu répondras dans le format suivant sans rien ajouter d'autre:
+"Titre du sujet 1
+Titre du sujet 2
+Titre du sujet 3
+..."
+"""

+PROMPT_SYSTEM_PART = """Tu es un agent dont le rôle est de créer une partie du résumé d'un compte rendu de réunion. Tu utiliseras un style synthétique, administratif, à la troisième personne, sans affect. Tu recevras en entrée le transcript, et le titre du sujet correspondant. Ta tâche est de rédiger un résumé concis de cette partie et uniquement cette partie, en te concentrant uniquement sur les informations essentielles et pertinentes. Le résumé de chaque partie doit tenir en 4 à 6 phrases maximum, sans entrer dans les détails mineurs. Tu répondras dans le format suivant :
+    ### Titre du sujet [Traduire ce titre selon la langue du transcript]
+    [Résumé concis et structuré de la partie du transcript]
    """

-    return [
-        {
-            "role": "system",
-            "content": "You are a concise and structured assistant, that summarizes meeting transcripts.",
-        },
-        {"role": "user", "content": prompt},
-    ]
+PROMPT_USER_PART = """Titre de la partie à résumer : {part}
+Transcript complet :
+{transcript}"""
+
+PROMPT_SYSTEM_CLEANING = """Tu es un agent dont le rôle est de nettoyer un résumé de compte rendu de réunion. Tu recevras en entrée le résumé brut, potentiellement avec des erreurs de formatage, des incohérences ou des redondances. Ta tâche est de corriger les erreurs de formatage, d'améliorer la clarté et la cohérence du texte, et de t'assurer que le résumé est bien structuré et facile à lire. Ton but principal est de retirer les redondances et les répétitions. Assure la cohérence entre les titres et homogénéise le style d’écriture entre les parties. Supprime les doublons d’informations entre les parties si présents. Si certaines parties sont plus secondaires, tu peux les fusionner ou les réduire en 1 à 2 phrases. Mets en avant les points centraux qui ont fait l’objet de décisions ou d’actions. Tu répondras uniquement avec le résumé sans rien ajouter d'autre"""
+
+PROMPT_SYSTEM_NEXT_STEP = """Tu es un agent dont le rôle est d'extraire les prochaines étapes d'un transcript de réunion. Tu utiliseras un style synthétique, administratif, à la troisième personne, sans affect. Tu recevras en entrée le transcript. Ta tâche est d'identifier et de lister toutes les actions à entreprendre, en indiquant la ou les personnes assignées et en précisant les échéances si elles sont mentionnées. Ne retiens que les actions concrètes et à venir. Ignore les remarques générales ou les constats sans suite. Les actions doivent suivre ce format strict :
+### Prochaines étapes
+- [ ] [Action à effectuer] Assignée à : [Nom], Échéance : [Date si mentionnée]"""
Author	SHA1	Message	Date
Martin Guitteny	c24c1729ef	🐛(summary) fix feature flag on summary job Sadly, we used user db id as the posthog distinct id of identified user, and not the sub. Before this commit, we were only passing sub to the summary microservice. Add the owner's id. Please note we introduce a different naming behavir, by prefixing the id with "owner". We didn't for the sub and the email. We cannot align sub and email with this new naming approach, because external contributors have already started building their own microservice.	2025-09-30 15:20:58 +02:00
lebaudantoine	a3ca6f0113	📈(frontend) track more room events in PostHog for disconnections Add additional room event tracking to PostHog analytics to better understand and diagnose disconnection error patterns. Enhanced telemetry will provide insights for improving connection stability.	2025-09-18 23:47:13 +02:00
lebaudantoine	1d9caeb17f	🐛(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.	2025-09-18 18:27:10 +02:00
lebaudantoine	5caed6222b	🐛(summary) fix transcribe job queue assignment Ensure transcribe jobs are properly assigned to their specific queue instead of using default queue. This prevents job routing issues and ensures proper task distribution across workers.	2025-09-18 18:27:10 +02:00
lebaudantoine	46fdbc0430	✨(helm) configure MinIO webhook with Kubernetes job for recordings Implement automated MinIO webhook configuration using Kubernetes job to enable recording feature functionality. This eliminates manual setup requirements and ensures consistent webhook configuration across deployments.	2025-09-18 18:27:10 +02:00
lebaudantoine	534f3b2d47	🐛(helm) fix MinIO webhook certificate after Tilt stack changes Restore certificate mounting for MinIO webhook communication to backend after migrating away from unmaintained Bitnami chart. Mount certificate in proper volume to enable secure bucket-to-backend webhook delivery.	2025-09-18 18:27:10 +02:00
lebaudantoine	ebf7a1956e	🔧(helm) configure Celery workers for summary microservice in Helm Add Celery summarize and transcribe worker configuration to Helm charts for summary microservice. Create new deployment resources and increment chart version to support distributed task processing.	2025-09-18 01:44:16 +02:00
lebaudantoine	c2e6927978	📝(summary) add minimal README for dev experience Basic README with developer setup info. Will be expanded with more details in future commits.	2025-09-18 00:56:00 +02:00
lebaudantoine	1b4a144650	🔧(summary) add settings to disable summary feature entirely Introduce FastAPI settings configuration option to completely disable the summary feature. This improves developer experience by allowing developers to skip summary-related setup when not needed for their workflow.	2025-09-18 00:56:00 +02:00
lebaudantoine	7004b7e2c8	🔧(summary) introduce watch section to Docker Compose file Add watch configuration to Docker Compose file enabling compose watch mode for Docker Compose 2.22+. This enhances developer experience on Visio by providing automatic file synchronization and hot reloading during development on the celery workers.	2025-09-18 00:56:00 +02:00
Martin Guitteny	848893a79f	🐛(backend) fix Docker Compose stack for recording features The recording feature and call to the summary service wasn't working in the docker compose stack. It was a pain for new developper joining the project to understand every piece of the stack. Resolve storage webhook trigger issues by configuring proper environment variables, settings, and MinIO setup to enhance developer experience and eliminate manual configuration requirements. Add new Makefile command to configure MinIO webhook via CLI since webhook configuration cannot be declared as code. Update summary microservice to reflect secure access false setting for MinIO bucket consistency with Tilt stack configuration.	2025-09-18 00:56:00 +02:00
lebaudantoine	849f8ac08c	✨(summary) introduce summary logic for meeting transcripts Implement summarization functionality that processes completed meeting transcripts to generate concise summaries. First draft base on a simple recursive agentic scenario. Observability and evaluation will be added in the next PRs.	2025-09-18 00:56:00 +02:00
lebaudantoine	9fd264ae0e	🔧(summary) specify dedicated transcription queue for Celery worker Name the Celery queue used by transcription worker to prepare for dedicated summarization queue separation, enabling faster transcript delivery while isolating new agentic logic in separate worker processes.	2025-09-18 00:56:00 +02:00
lebaudantoine	bfdf5548a0	🔧(backend) rename OpenAI settings to WhisperX to avoid confusion Rename incorrectly named OpenAI configuration settings since they're used to instantiate WhisperX client which is not OpenAI compatible, preventing confusion about actual service dependencies.	2025-09-18 00:56:00 +02:00
lebaudantoine	0102b428f1	📦️(summary) vendor existing logic for agentic system transition Vendoring dead code before introducing new agent-based summarization architecture to maintain clean code.	2025-09-18 00:56:00 +02:00
lebaudantoine	91a8d85db3	🔧(summary) add PostHog configuration example to summary env file Include PostHog analytics configuration example in the summary environment file with default disabled state. This provides developers with clear setup guidance while maintaining privacy-first defaults.	2025-09-18 00:56:00 +02:00
lebaudantoine	e301c5deed	✨(summary) wrap PostHog feature flag checks in analytics client Encapsulate PostHog SDK feature flag functionality within analytics client.	2025-09-18 00:56:00 +02:00
lebaudantoine	67b046c9ba	♻️(summary) integrate summary Docker compose into global dev tooling Consolidate summary service into main development stack to centralize development environment management and simplify service orchestration with shared infrastructure like MinIO storage.	2025-09-18 00:56:00 +02:00
lebaudantoine	1b3b9ff858	✨(summary) add development stage to summary Docker image for hot reload Introduce new Docker stage enabling hot reload during active API development to eliminate rebuild cycles and improve developer workflow efficiency.	2025-09-18 00:56:00 +02:00
lebaudantoine	64fca531fa	🔖(minor) bump release to 0.1.38 - bump LiveKit dependencies - fix some regressions link to permissions	2025-09-18 00:43:47 +02:00
lebaudantoine	e73b0777e3	📱(frontend) fix permission modal width on mobile screens Adjust permission modal dimensions to properly fit mobile viewports and prevent poor responsive user experience. Ensures modal content remains accessible and readable across different screen sizes.	2025-09-18 00:35:50 +02:00
lebaudantoine	0489033e03	🚑️(frontend) fix mobile permission deadlock with disabled tracks Resolve issue where users with disabled track preferences in local storage wouldn't receive permission prompts in subsequent sessions, causing app deadlock. Toggle tracks when permissions are disabled to re-trigger permission requests. This is a hotfix addressing critical user feedback. Permission handling requires further testing and improvements based on gathered user reports since release.	2025-09-18 00:35:50 +02:00
lebaudantoine	04710f5ecd	🐛(frontend) fix mic mute for non-admin users in participant list Resolve regression where non-admin/anonymous users couldn't mute their microphone from participant list after mute permissions refactoring. Replace API call with local track mute for better performance and proper permission handling.	2025-09-18 00:35:50 +02:00
lebaudantoine	4afa03d7c8	⬆️(frontend) bump livekit-track-processor to 0.6.1 Update livekit-track-processor dependency from previous version to 0.6.1 to incorporate latest bug fixes and feature improvements.	2025-09-18 00:35:50 +02:00
lebaudantoine	e57685ebe3	⬆️(frontend) bump livekit-client to 2.15.7 Update livekit-client dependency from previous version to 2.15.7 to incorporate latest bug fixes and feature improvements.	2025-09-18 00:35:50 +02:00
lebaudantoine	381b7c4eb7	♿️(frontend) add missing aria-label to screenshare button Add accessibility label to screenshare control button to ensure screen readers can properly announce the button's function to users with visual impairments.	2025-09-16 14:52:40 +02:00
lebaudantoine	e0fe78e3fa	🔖(minor) bump release to 0.1.37 - revert dynacast / simulcast change - fix safari audio output selector	2025-09-15 23:32:43 +02:00
lebaudantoine	2a85f45e69	🐛(frontend) prevent displaying audio output selector to Safari users Hide audio output selector component for Safari browsers due to lack of native support for audio output device selection APIs. This prevents user confusion and improves browser compatibility.	2025-09-15 18:39:48 +02:00
lebaudantoine	8aa035ae00	⏪️(frontend) revert dynacast and adaptive streaming checks Revert recent changes to dynacast and adaptive streaming functionality to isolate potential causes of regression issues. Changes will be reintroduced in future commits with improved error handling and thorough investigation of root causes.	2025-09-15 15:54:47 +02:00
lebaudantoine	d39d02d445	🔖(minor) bump release to 0.1.36	2025-09-10 22:05:39 +02:00
lebaudantoine	e28e0024be	⬆️(backend) bump Django to 5.2.6 to fix severe security issue Upgrade Django from previous version to 5.2.6 to address critical security vulnerabilities: https://www.djangoproject.com/weblog/2025/sep/03/security-releases/	2025-09-10 21:32:09 +02:00
lebaudantoine	c492243ab1	🐛(frontend) fix controlbar mobile responsiveness after refactor Restore proper controlbar layout and spacing on mobile screens that broke during recent audio control component refactoring, ensuring consistent user interface across all device sizes.	2025-09-10 21:32:09 +02:00
lebaudantoine	38e6adf811	⬇️(frontend) downgrade livekit-js-sdk to troubleshoot production issues Temporarily roll back LiveKit client SDK version to investigate and resolve production stability problems that emerged after recent upgrade, enabling system restoration while root cause analysis is performed.	2025-09-10 21:32:09 +02:00