Coverage for app/celery_app.py: 100.00%

1from celery import Celery 

2 

3from .config import settings 

4 

5celery_app = Celery("worker", broker=settings.CELERY_BROKER_URL) # no include here 

6 

7celery_app.conf.update( 

8 broker_url=settings.CELERY_BROKER_URL, 

9 result_backend=settings.CELERY_RESULT_BACKEND, 

10 

11 task_serializer="json", 

12 accept_content=["json"], 

13 result_serializer="json", 

14 

15 task_track_started=True, 

16 task_send_sent_event=True, 

17 result_extended=True, 

18) 

19 

20if __name__ == "__main__": 

21 celery_app.start()