diff --git a/apps/api/app/tasks/lipsync_tts.py b/apps/api/app/tasks/lipsync_tts.py
index 45e1ed11e..6c9fa417e 100644
--- a/apps/api/app/tasks/lipsync_tts.py
+++ b/apps/api/app/tasks/lipsync_tts.py
@@ -15,7 +15,7 @@ import io
 import logging
 from datetime import datetime, timezone
 
-from apps.worker.worker_app.celery_app import celery_app
+from app.core.celery_app import celery_app
 
 logger = logging.getLogger(__name__)