25 lines
680 B
Python
25 lines
680 B
Python
"""Celery task module imports.
|
|
|
|
Celery autodiscover imports ``app.tasks``; importing task modules here ensures
|
|
custom named tasks are registered when workers start.
|
|
"""
|
|
|
|
import logging
|
|
|
|
logger = logging.getLogger("video_gen")
|
|
|
|
try:
|
|
from app.tasks import ( # noqa: F401
|
|
generation_create_tasks,
|
|
generation_poll_tasks,
|
|
generation_download_tasks,
|
|
generation_recovery_tasks,
|
|
hot_opening_replicate_tasks,
|
|
shot_replicate_tasks,
|
|
shot_replicate_flow_tasks,
|
|
module_async_recovery_tasks,
|
|
)
|
|
except Exception:
|
|
logger.exception("Celery 任务模块导入失败，worker 可能出现 unregistered task。")
|
|
raise
|