ericxiao251 commented on issue #28655:
URL: https://github.com/apache/airflow/issues/28655#issuecomment-3648428569
@dintorf would you be able to help me debug my problem? I'm using Airflow
1.18.0 helm charts, I have this defined in my values:
```yaml
airflow:
enableBuiltInSecretEnvVars:
AIRFLOW__CORE__FERNET_KEY: false
AIRFLOW__WEBSERVER__SECRET_KEY: false
AIRFLOW__CELERY__BROKER_URL: true
AIRFLOW__CELERY__RESULT_BACKEND: true
secret:
- envName: AIRFLOW__CELERY_BROKER_TRANSPORT_OPTIONS__MASTER_NAME
secretName: airflow-2-env-secret
secretKey: AIRFLOW__CELERY_BROKER_TRANSPORT_OPTIONS__MASTER_NAME
- envName: AIRFLOW__CELERY_BROKER_TRANSPORT_OPTIONS__SENTINEL_KWARGS
secretName: airflow-2-env-secret
secretKey: AIRFLOW__CELERY_BROKER_TRANSPORT_OPTIONS__SENTINEL_KWARGS
- envName: BROKER_URL
secretName: airflow-2-env-secret
secretKey: BROKER_URL
config:
celery:
celery_config_options: celery_config_extend.MY_CELERY_CONFIG
flower:
extraVolumes:
- name: celery-config
configMap:
name: airflow-2-celery-config
extraVolumeMounts:
- name: celery-config
mountPath: /usr/local/airflow/config/celery_config_extend.py
subPath: celery_config_extend.py
```
```yaml
apiVersion: v1
kind: ConfigMap
metadata:
name: airflow-2-celery-config
labels:
app.kubernetes.io/name: airflow
app.kubernetes.io/component: celery
data:
celery_config_extend.py: |
from airflow.config_templates.default_celery import DEFAULT_CELERY_CONFIG
MY_CELERY_CONFIG = {
**DEFAULT_CELERY_CONFIG,
broker_url: '{{ $secrets.AIRFLOW__CELERY__BROKER_URL }}',
}
if "broker_transport_options" in MY_CELERY_CONFIG:
MY_CELERY_CONFIG["broker_transport_options"]["sentinel_kwargs"] = {
"password": '{{ $secrets._REDIS_PASSWORD }}' }
MY_CELERY_CONFIG["broker_transport_options"]["master_name"] =
"mymaster"
else:
MY_CELERY_CONFIG["broker_transport_options"] = {
"sentinel_kwargs": { "password": '{{ $secrets._REDIS_PASSWORD
}}' }
"master_name": "mymaster"
}
```
```yaml
-- airflow-2-env-secret
apiVersion: v1
data:
AIRFLOW__CELERY_BROKER_TRANSPORT_OPTIONS__MASTER_NAME: ++++++++
AIRFLOW__CELERY_BROKER_TRANSPORT_OPTIONS__SENTINEL_KWARGS: ++++++++
AIRFLOW__CELERY__BROKER_URL: ++++++++
AIRFLOW__CELERY__CELERY_CONFIG_OPTIONS: ++++++++
BROKER_URL: ++++++++
_REDIS_PASSWORD: ++++++++
connection: ++++++++
redis_connection: ++++++++
```
---
I get this exception in my flower pod:
```
kombu.exceptions.OperationalError: [Errno
111] Connection refused
[2025-12-12 22:51:43,933] {connection.py:630}
WARNING - No hostname was supplied. Reverting to default 'localhost'
[2025-12-12 22:51:43,983] {connection.py:630}
WARNING - No hostname was supplied. Reverting to default 'localhost'
```
I get this exception in my worker pod:
```
[2025-12-12 22:51:26,400:
WARNING/MainProcess] No hostname was supplied. Reverting to default 'localhost'
-------------- celery@airflow-2-worker-0
v5.2.7 (dawn-chorus)
--- ***** -----
-- ******* ----
Linux-6.1.158-x86_64-with-debian-11.3 2025-12-12 22:51:26
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app:
airflow.executors.celery_executor:0x7f2b9ba2c0d0
- ** ---------- .> transport:
amqp://guest:**@localhost:5672//
- ** ---------- .> results: disabled://
- *** --- * --- .> concurrency: 16 (prefork)
-- ******* ---- .> task events: OFF (enable
-E to monitor tasks in this worker)
--- ***** -----
-------------- [queues]
.> default
exchange=default(direct) key=default
[tasks]
.
airflow.executors.celery_executor.execute_command
2025-12-12T22:51:28.418646281Z [2025-12-12 22:51:28,418: ERROR/MainProcess]
consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 111]
Connection refused.
Trying again in 2.00 seconds... (1/100)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
