diff --git a/server/reflector/pipelines/main_live_pipeline.py b/server/reflector/pipelines/main_live_pipeline.py
index aca28586..3a4c36be 100644
--- a/server/reflector/pipelines/main_live_pipeline.py
+++ b/server/reflector/pipelines/main_live_pipeline.py
@@ -15,9 +15,10 @@ import asyncio
 import functools
 from contextlib import asynccontextmanager
 
+import boto3
 from celery import chord, group, shared_task
 from pydantic import BaseModel
-from reflector.db.meetings import meetings_controller
+from reflector.db.meetings import meeting_consent_controller, meetings_controller
 from reflector.db.recordings import recordings_controller
 from reflector.db.rooms import rooms_controller
 from reflector.db.transcripts import (
@@ -53,25 +54,29 @@ from reflector.processors.types import (
 )
 from reflector.processors.types import Transcript as TranscriptProcessorType
 from reflector.settings import settings
+from reflector.storage import get_transcripts_storage
 from reflector.ws_manager import WebsocketManager, get_ws_manager
 from reflector.zulip import (
     get_zulip_message,
     send_message_to_zulip,
     update_zulip_message,
 )
-
-from reflector.db.meetings import meeting_consent_controller
-from reflector.storage import get_transcripts_storage
-
-import boto3
-
 from structlog import BoundLogger as Logger
 
 
 def asynctask(f):
     @functools.wraps(f)
     def wrapper(*args, **kwargs):
-        coro = f(*args, **kwargs)
+        async def run_with_db():
+            from reflector.db import database
+
+            await database.connect()
+            try:
+                return await f(*args, **kwargs)
+            finally:
+                await database.disconnect()
+
+        coro = run_with_db()
         try:
             loop = asyncio.get_running_loop()
         except RuntimeError:
@@ -595,7 +600,6 @@ async def cleanup_consent(transcript: Transcript, logger: Logger):
     logger.info("Consent denied, cleaning up all related audio files")
 
     if recording and recording.bucket_name and recording.object_key:
-
         s3_whereby = boto3.client(
             "s3",
             aws_access_key_id=settings.AWS_WHEREBY_ACCESS_KEY_ID,
@@ -615,7 +619,6 @@ async def cleanup_consent(transcript: Transcript, logger: Logger):
     await transcripts_controller.update(transcript, {"audio_deleted": True})
     # 2. Delete processed audio from transcript storage S3 bucket
     if transcript.audio_location == "storage":
-
         storage = get_transcripts_storage()
         try:
             await storage.delete_file(transcript.storage_audio_path)