We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents f7b8169 + b72a736 commit f62787bCopy full SHA for f62787b
config/celery_app.py
@@ -6,6 +6,7 @@
6
from celery.schedules import crontab
7
from celery.signals import setup_logging, worker_ready, worker_shutdown
8
from django.conf import settings
9
+from django_structlog.celery.steps import DjangoStructLogInitStep
10
11
# set the default Django settings module for the 'celery' program.
12
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings.production")
@@ -18,6 +19,8 @@
18
19
# should have a `CELERY_` prefix.
20
app.config_from_object("django.conf:settings", namespace="CELERY")
21
22
+app.steps["worker"].add(DjangoStructLogInitStep)
23
+
24
25
@setup_logging.connect
26
def config_loggers(*args, **kwargs):
0 commit comments