feat: use celery structlog logging

config/celery_app.py

@@ -1,9 +1,11 @@
 import os
+from logging.config import dictConfig
 from pathlib import Path
 
 from celery import Celery, bootsteps
 from celery.schedules import crontab
-from celery.signals import worker_ready, worker_shutdown
+from celery.signals import setup_logging, worker_ready, worker_shutdown
+from django.conf import settings
 
 # set the default Django settings module for the 'celery' program.
 os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings.production")
@@ -17,6 +19,11 @@
 app.config_from_object("django.conf:settings", namespace="CELERY")
 
 
+@setup_logging.connect
+def config_loggers(*args, **kwargs):
+    dictConfig(settings.LOGGING)
+
+
 HEARTBEAT_FILE = Path("/tmp/worker_heartbeat")
 READINESS_FILE = Path("/tmp/worker_ready")