This is an automated email from the ASF dual-hosted git repository.
hussein-awala pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 926a8c62c55 Fix Celery worker JSON logging config for teams (#69139)
926a8c62c55 is described below
commit 926a8c62c553bf37df09cba1fd5515ee55129754
Author: Henry Chen <[email protected]>
AuthorDate: Tue Jun 30 06:38:43 2026 +0800
Fix Celery worker JSON logging config for teams (#69139)
---
providers/celery/src/airflow/providers/celery/cli/celery_command.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/providers/celery/src/airflow/providers/celery/cli/celery_command.py
b/providers/celery/src/airflow/providers/celery/cli/celery_command.py
index ed5b83c4478..6e16888a142 100644
--- a/providers/celery/src/airflow/providers/celery/cli/celery_command.py
+++ b/providers/celery/src/airflow/providers/celery/cli/celery_command.py
@@ -263,11 +263,11 @@ def worker(args):
if AIRFLOW_V_3_0_PLUS:
from airflow.sdk.log import configure_logging
- _celery_json = conf.get("celery", "json_logs", fallback="")
+ _celery_json = config.get("celery", "json_logs", fallback="")
if _celery_json and _celery_json.lower() != "none":
- json_output = conf.getboolean("celery", "json_logs")
+ json_output = config.getboolean("celery", "json_logs")
else:
- json_output = conf.getboolean("logging", "json_logs",
fallback=False)
+ json_output = config.getboolean("logging", "json_logs",
fallback=False)
configure_logging(output=sys.stdout.buffer, json_output=json_output)
else:
# Disable connection pool so that celery worker does not hold an
unnecessary db connection
