backend/app/workers/celery_app.py

20 lines · python

from celery import Celery
 
from app.core.config import settings
 
celery_app = Celery(
    "sightline",
    broker=settings.redis_url,
    backend=settings.redis_url,
    include=["app.workers.tasks"],
)
celery_app.conf.update(task_serializer="json", result_serializer="json",
                       accept_content=["json"], task_track_started=True,
                       broker_connection_retry_on_startup=True)
 
celery_app.conf.beat_schedule = {
    "daily-retention": {
        "task": "sightline.apply_retention",
        "schedule": 24 * 60 * 60.0,
    },
}

1	from celery import Celery
2
3	from app.core.config import settings
4
5	celery_app = Celery(
6	"sightline",
7	broker=settings.redis_url,
8	backend=settings.redis_url,
9	include=["app.workers.tasks"],
10	)
11	celery_app.conf.update(task_serializer="json", result_serializer="json",
12	accept_content=["json"], task_track_started=True,
13	broker_connection_retry_on_startup=True)
14
15	celery_app.conf.beat_schedule = {
16	"daily-retention": {
17	"task": "sightline.apply_retention",
18	"schedule": 24 * 60 * 60.0,
19	},
20	}