app.py 349 B

123456789101112
  1. from celery import Celery
  2. from worker.celery import celeryconfig
  3. app = Celery(
  4. 'search_worker',
  5. include=[
  6. 'worker.celery.search_tasks', # 取消注释原始任务模块
  7. 'worker.celery.crawl_tasks',
  8. 'worker.celery.html_convert_tasks' # 注册新的 Pandoc 任务模块
  9. ]
  10. )
  11. app.config_from_object(celeryconfig)