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