worker_1 | Restoring 7 unacknowledged message(s)
worker_1 | Traceback (most recent call last):
worker_1 | File “/usr/local/lib/python2.7/site-packages/celery/worker/consumer/consumer.py”, line 316, in start
worker_1 | blueprint.start(self)
worker_1 | File “/usr/local/lib/python2.7/site-packages/celery/bootsteps.py”, line 119, in start
worker_1 | step.start(parent)
worker_1 | File “/usr/local/lib/python2.7/site-packages/celery/worker/consumer/consumer.py”, line 592, in start
worker_1 | c.loop(*c.loop_args())
worker_1 | File “/usr/local/lib/python2.7/site-packages/celery/worker/loops.py”, line 91, in asynloop
worker_1 | next(loop)
worker_1 | File “/usr/local/lib/python2.7/site-packages/kombu/asynchronous/hub.py”, line 354, in create_loop
worker_1 | cb(*cbargs)
worker_1 | File “/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py”, line 1047, in on_readable
worker_1 | self.cycle.on_readable(fileno)
worker_1 | File “/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py”, line 344, in on_readable
worker_1 | chan.handlerstype
worker_1 | File “/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py”, line 721, in _brpop_read
worker_1 | **options)
worker_1 | File “/usr/local/lib/python2.7/site-packages/redis/client.py”, line 680, in parse_response
worker_1 | response = connection.read_response()
worker_1 | File “/usr/local/lib/python2.7/site-packages/redis/connection.py”, line 624, in read_response
worker_1 | response = self._parser.read_response()
worker_1 | File “/usr/local/lib/python2.7/site-packages/redis/connection.py”, line 403, in read_response
worker_1 | (e.args,))
worker_1 | ConnectionError: Error while reading from socket: (‘Connection closed by server.’,)
worker_1 | 21:31:11 [WARNING] celery.worker.consumer.consumer: consumer: Connection to broker lost. Trying to re-establish the connection…
Hello Amit, I have the same issue did you get any workaround for this?