You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug
I am currently running Airflow in docker, which employs the CeleryExecutor. Celery utilizes a Redis Sentinel cluster with ACL enabled as the message broker. When starting flower, it seems ok, but when I press the Broker tab, the following error message occurs:
$ sudo docker logs --tail 100 -f airflow-flower-1
BACKEND=sentinel
DB_HOST=xxxxxxx
DB_PORT=26379
[2024-07-25T18:25:09.734+0800] {selector_events.py:54} DEBUG - Using selector: EpollSelector
[2024-07-25T18:25:09.986+0800] {command.py:168} INFO - Visit me at http://0.0.0.0:5555
[2024-07-25T18:25:09.992+0800] {command.py:176} INFO - Broker: sentinel://xxxx:**@XXXXXXX:26379/5
[2024-07-25T18:27:11.775+0800] {broker.py:31} ERROR - Unable to get queues: 'invalid username-password pair or user is disabled.'
[2024-07-25T18:27:11.776+0800] {web.py:1875} ERROR - Uncaught exception GET /broker (xxxxxxx)
HTTPServerRequest(protocol='http', host='xxxxxxx:5555', method='GET', uri='/broker', version='HTTP/1.1', remote_ip='xxxxxxx')
Traceback (most recent call last):
File "/home/airflow/.local/lib/python3.11/site-packages/tornado/web.py", line 1790, in _execute
result = await result
^^^^^^^^^^^^
File "/home/airflow/.local/lib/python3.11/site-packages/flower/views/broker.py", line 35, in get
queues=queues)
^^^^^^
UnboundLocalError: cannot access local variable 'queues' where it is not associated with a value
[2024-07-25T18:27:11.787+0800] {web.py:2348} ERROR - 500 GET /broker (xxxxxxx) 14.77ms
To Reproduce
Steps to reproduce the behavior:
Press the Broker tab
Expected behavior
Why does this error occur, and how can it be resolved?
System information
docker image:airflow:2.8.4-python3.11
thanks!
The text was updated successfully, but these errors were encountered:
Describe the bug
I am currently running Airflow in docker, which employs the CeleryExecutor. Celery utilizes a Redis Sentinel cluster with ACL enabled as the message broker. When starting flower, it seems ok, but when I press the Broker tab, the following error message occurs:
$ sudo docker logs --tail 100 -f airflow-flower-1
BACKEND=sentinel
DB_HOST=xxxxxxx
DB_PORT=26379
[2024-07-25T18:25:09.734+0800] {selector_events.py:54} DEBUG - Using selector: EpollSelector
[2024-07-25T18:25:09.986+0800] {command.py:168} INFO - Visit me at http://0.0.0.0:5555
[2024-07-25T18:25:09.992+0800] {command.py:176} INFO - Broker: sentinel://xxxx:**@XXXXXXX:26379/5
[2024-07-25T18:27:11.775+0800] {broker.py:31} ERROR - Unable to get queues: 'invalid username-password pair or user is disabled.'
[2024-07-25T18:27:11.776+0800] {web.py:1875} ERROR - Uncaught exception GET /broker (xxxxxxx)
HTTPServerRequest(protocol='http', host='xxxxxxx:5555', method='GET', uri='/broker', version='HTTP/1.1', remote_ip='xxxxxxx')
Traceback (most recent call last):
File "/home/airflow/.local/lib/python3.11/site-packages/tornado/web.py", line 1790, in _execute
result = await result
^^^^^^^^^^^^
File "/home/airflow/.local/lib/python3.11/site-packages/flower/views/broker.py", line 35, in get
queues=queues)
^^^^^^
UnboundLocalError: cannot access local variable 'queues' where it is not associated with a value
[2024-07-25T18:27:11.787+0800] {web.py:2348} ERROR - 500 GET /broker (xxxxxxx) 14.77ms
To Reproduce
Steps to reproduce the behavior:
Expected behavior
Why does this error occur, and how can it be resolved?
System information
docker image:airflow:2.8.4-python3.11
thanks!
The text was updated successfully, but these errors were encountered: