Danirill commented on issue #15799:
URL: https://github.com/apache/airflow/issues/15799#issuecomment-855257409
Hello, i don't have airflow, but got the same error. There is my django app
log:
```
[2021-06-05 15:30:08,313: DEBUG/MainProcess] Channel open
[2021-06-05 15:30:08,314: CRITICAL/MainProcess] Unrecoverable error:
PreconditionFailed(406, 'PRECONDITION_FAILED - consumer ack timed out on
channel 1', (0, 0), '')
Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/celery/worker/worker.py",
line 203, in start
self.blueprint.start(self)
File "/usr/local/lib/python3.7/site-packages/celery/bootsteps.py", line
116, in start
step.start(parent)
File "/usr/local/lib/python3.7/site-packages/celery/bootsteps.py", line
365, in start
return self.obj.start()
File
"/usr/local/lib/python3.7/site-packages/celery/worker/consumer/consumer.py",
line 326, in start
blueprint.start(self)
File "/usr/local/lib/python3.7/site-packages/celery/bootsteps.py", line
116, in start
step.start(parent)
File
"/usr/local/lib/python3.7/site-packages/celery/worker/consumer/consumer.py",
line 618, in start
c.loop(*c.loop_args())
File "/usr/local/lib/python3.7/site-packages/celery/worker/loops.py", line
81, in asynloop
next(loop)
File "/usr/local/lib/python3.7/site-packages/kombu/asynchronous/hub.py",
line 361, in create_loop
cb(*cbargs)
File "/usr/local/lib/python3.7/site-packages/kombu/transport/base.py",
line 235, in on_readable
reader(loop)
File "/usr/local/lib/python3.7/site-packages/kombu/transport/base.py",
line 217, in _read
drain_events(timeout=0)
File "/usr/local/lib/python3.7/site-packages/amqp/connection.py", line
523, in drain_events
while not self.blocking_read(timeout):
File "/usr/local/lib/python3.7/site-packages/amqp/connection.py", line
529, in blocking_read
return self.on_inbound_frame(frame)
File "/usr/local/lib/python3.7/site-packages/amqp/method_framing.py", line
53, in on_frame
callback(channel, method_sig, buf, None)
File "/usr/local/lib/python3.7/site-packages/amqp/connection.py", line
536, in on_inbound_method
method_sig, payload, content,
File "/usr/local/lib/python3.7/site-packages/amqp/abstract_channel.py",
line 143, in dispatch_method
listener(*args)
File "/usr/local/lib/python3.7/site-packages/amqp/channel.py", line 278,
in _on_close
reply_code, reply_text, (class_id, method_id), ChannelError,
amqp.exceptions.PreconditionFailed: (0, 0): (406) PRECONDITION_FAILED -
consumer ack timed out on channel 1
[2021-06-05 15:30:08,352: DEBUG/MainProcess] Closed channel #3
[2021-06-05 15:30:08,408: DEBUG/MainProcess] Closed channel #2
[2021-06-05 15:30:09,474: DEBUG/MainProcess] Closed channel #1
[2021-06-05 15:30:09,481: DEBUG/MainProcess] Closed channel #1
```
Error repeats periodically. I tried to solve this problem by aading this
code to settings.py:
```
BROKER_POOL_LIMIT = 10
CELERYD_FORCE_EXECV = True
CELERY_TASK_RESULT_EXPIRES = 3600
CELERYD_POOL_RESTARTS = True
CELERY_ACKS_LATE = True
CELERYD_PREFETCH_MULTIPLIER = 1
```
But it gave no results.
Thanks
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
