523ac85a35
Two fixes: 1. Snap pause point to gap.start (end of previous word) to prevent cutting off the first word after the pause 2. Add explicit whisper_transcribe import in celery_worker.py 3. Fix misleading queue log message 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
46 lines
1.7 KiB
Python
46 lines
1.7 KiB
Python
import sentry_sdk
|
|
from sentry_sdk.integrations.celery import CeleryIntegration
|
|
|
|
from app.core.config import settings
|
|
from app.core.logging import setup_logging, get_logger
|
|
from app.tasks import celery_app
|
|
|
|
# Set up logging first
|
|
setup_logging()
|
|
logger = get_logger(__name__)
|
|
|
|
# Initialize Sentry for worker
|
|
if settings.sentry_dsn and settings.sentry_dsn.startswith(('http', 'https')):
|
|
sentry_sdk.init(
|
|
dsn=settings.sentry_dsn,
|
|
integrations=[CeleryIntegration(monitor_beat_tasks=True)],
|
|
environment=settings.app_env,
|
|
release="1.0.0",
|
|
send_default_pii=False,
|
|
)
|
|
|
|
logger.info("Starting Celery worker with structured logging")
|
|
|
|
# Import task modules to register them
|
|
from app.tasks import ingest_and_ai
|
|
from app.tasks import translate_and_synthesize
|
|
from app.tasks import render_accessible_video
|
|
from app.tasks import ffmpeg_operations
|
|
from app.tasks import whisper_transcribe
|
|
|
|
# Debug: Show registered tasks
|
|
logger.info(f"Celery app: {celery_app}")
|
|
logger.info(f"Registered tasks: {list(celery_app.tasks.keys())}")
|
|
logger.info(f"Task routes: {celery_app.conf.task_routes}")
|
|
# Note: Actual queue listening is determined by -Q argument passed to celery worker command
|
|
logger.info("Task modules loaded. Queues determined by celery -Q argument.")
|
|
|
|
# Specifically check for our translation task
|
|
if 'app.tasks.translate_and_synthesize.translate_and_synthesize_task' in celery_app.tasks:
|
|
logger.info("✅ translate_and_synthesize_task is registered")
|
|
else:
|
|
logger.error("❌ translate_and_synthesize_task is NOT registered")
|
|
logger.error(f"Available tasks: {[t for t in celery_app.tasks.keys() if not t.startswith('celery.')]}")
|
|
|
|
if __name__ == "__main__":
|
|
celery_app.start()
|