|
84 | 84 | DD_CELERY_BEAT_SCHEDULE_FILENAME=(str, root("dojo.celery.beat.db")),
|
85 | 85 | DD_CELERY_TASK_SERIALIZER=(str, "pickle"),
|
86 | 86 | DD_CELERY_PASS_MODEL_BY_ID=(str, True),
|
| 87 | + DD_CELERY_LOG_LEVEL=(str, "INFO"), |
87 | 88 | DD_FOOTER_VERSION=(str, ""),
|
88 | 89 | # models should be passed to celery by ID, default is False (for now)
|
89 | 90 | DD_FORCE_LOWERCASE_TAGS=(bool, True),
|
@@ -1149,6 +1150,7 @@ def saml2_attrib_map_format(din):
|
1149 | 1150 | CELERY_ACCEPT_CONTENT = ["pickle", "json", "msgpack", "yaml"]
|
1150 | 1151 | CELERY_TASK_SERIALIZER = env("DD_CELERY_TASK_SERIALIZER")
|
1151 | 1152 | CELERY_PASS_MODEL_BY_ID = env("DD_CELERY_PASS_MODEL_BY_ID")
|
| 1153 | +CELERY_LOG_LEVEL = env("DD_CELERY_LOG_LEVEL") |
1152 | 1154 |
|
1153 | 1155 | if len(env("DD_CELERY_BROKER_TRANSPORT_OPTIONS")) > 0:
|
1154 | 1156 | CELERY_BROKER_TRANSPORT_OPTIONS = json.loads(env("DD_CELERY_BROKER_TRANSPORT_OPTIONS"))
|
@@ -1706,7 +1708,7 @@ def saml2_attrib_map_format(din):
|
1706 | 1708 | },
|
1707 | 1709 | "celery": {
|
1708 | 1710 | "handlers": [rf"{LOGGING_HANDLER}"],
|
1709 |
| - "level": str(LOG_LEVEL), |
| 1711 | + "level": str(CELERY_LOG_LEVEL), |
1710 | 1712 | "propagate": False,
|
1711 | 1713 | # workaround some celery logging known issue
|
1712 | 1714 | "worker_hijack_root_logger": False,
|
|
0 commit comments