celery_worker.py 405 B

123456789101112131415
  1. #!/usr/bin/env python
  2. """Celery worker entry point"""
  3. import os
  4. from app import create_app
  5. from app.celery_app import celery_app, init_celery
  6. # Create Flask app and initialize Celery
  7. flask_app = create_app(os.environ.get('FLASK_ENV', 'development'))
  8. init_celery(flask_app)
  9. # Import tasks to register them
  10. from app.tasks import scan_tasks # noqa: F401
  11. if __name__ == '__main__':
  12. celery_app.start()