fix: Add structlog init step celery

config/celery_app.py

@@ -6,6 +6,7 @@
 from celery.schedules import crontab
 from celery.signals import setup_logging, worker_ready, worker_shutdown
 from django.conf import settings
+from django_structlog.celery.steps import DjangoStructLogInitStep
 
 # set the default Django settings module for the 'celery' program.
 os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings.production")
@@ -18,6 +19,8 @@
 #   should have a `CELERY_` prefix.
 app.config_from_object("django.conf:settings", namespace="CELERY")
 
+app.steps["worker"].add(DjangoStructLogInitStep)
+
 
 @setup_logging.connect
 def config_loggers(*args, **kwargs):