schon/evibes/settings/celery.py
Egor fureunoir Gorbunov 597e7b98c4 Features: 1) Add task queue options for Celery scheduled tasks.
Fixes: None.

Extra: 1) Minor adjustments to Celery configuration.
2025-07-01 22:53:48 +03:00

36 lines
1.2 KiB
Python

from datetime import timedelta
from evibes.settings import REDIS_PASSWORD
CELERY_BROKER_URL = f"redis://:{REDIS_PASSWORD + '@'}redis:6379/0"
CELERY_RESULT_BACKEND = f"redis://:{REDIS_PASSWORD + '@'}redis:6379/0"
CELERY_BEAT_SCHEDULER = "django_celery_beat.schedulers.DatabaseScheduler"
CELERY_BEAT_SCHEDULE = {
"update_products_task": {
"task": "core.tasks.update_products_task",
"schedule": timedelta(minutes=60),
"options": {"queue": "stock_updater"},
},
"update_orderproducts_task": {
"task": "core.tasks.update_orderproducts_task",
"schedule": timedelta(minutes=1),
"options": {"queue": "default"},
},
"set_default_caches_task": {
"task": "core.tasks.set_default_caches_task",
"schedule": timedelta(hours=4),
"options": {"queue": "default"},
},
"remove_stale_product_images": {
"task": "core.tasks.remove_stale_product_images",
"schedule": timedelta(days=1),
"options": {"queue": "default"},
},
"process_promotions": {
"task": "core.tasks.process_promotions",
"schedule": timedelta(hours=2),
"options": {"queue": "default"},
},
}