Egor fureunoir Gorbunov
fabb3b5866
Fixes: 1) Correct type signature in `validate` method for serializers. Extra: 1) Remove redundant worker log format configurations in Celery; 2) Simplify log message format in log configuration for conciseness.
26 lines
600 B
Python
26 lines
600 B
Python
import os
|
|
|
|
from celery import Celery
|
|
|
|
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "evibes.settings")
|
|
|
|
app = Celery("evibes")
|
|
|
|
app.conf.update(
|
|
worker_hijack_root_logger=False,
|
|
broker_connection_retry_on_startup=True,
|
|
task_serializer="json",
|
|
result_serializer="json",
|
|
result_compression="zlib",
|
|
accept_content=["json"],
|
|
task_acks_late=True,
|
|
task_reject_on_worker_lost=True,
|
|
)
|
|
|
|
app.conf.task_routes = {
|
|
"core.tasks.update_products_task": {"queue": "stock_updater"},
|
|
}
|
|
|
|
app.config_from_object("django.conf:settings", namespace="CELERY")
|
|
|
|
app.autodiscover_tasks()
|