我的celery 任務是執行一個異步的圖片識別,但當我呼叫幾次之后就報出這個錯誤,celery 結合Rabbitmq,celery 版本:3.1
[2020-06-01 13:24:26,094: ERROR/MainProcess] Unrecoverable error: UnboundLocalError("local variable 'chunk' referenced before assignment",)
Traceback (most recent call last):
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/__init__.py", line 208, in start
self.blueprint.start(self)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 127, in start
step.start(parent)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 378, in start
return self.obj.start()
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/consumer.py", line 271, in start
blueprint.start(self)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 127, in start
step.start(parent)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/consumer.py", line 766, in start
c.loop(*c.loop_args())
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/loops.py", line 72, in asynloop
next(loop)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/kombu/async/hub.py", line 328, in create_loop
next(cb)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/concurrency/asynpool.py", line 186, in _recv_message
n = len(chunk)
UnboundLocalError: local variable 'chunk' referenced before assignment
[2020-06-01 13:24:26,095: DEBUG/MainProcess] | Worker: Closing Hub...
[2020-06-01 13:24:26,095: DEBUG/MainProcess] | Worker: Closing Pool...
[2020-06-01 13:24:26,095: DEBUG/MainProcess] | Worker: Closing Consumer...
[2020-06-01 13:24:26,095: DEBUG/MainProcess] | Worker: Stopping Consumer...
[2020-06-01 13:24:26,095: DEBUG/MainProcess] | Consumer: Closing Connection...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing Events...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing Gossip...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing Mingle...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing Control...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing Tasks...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing Heart...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Closing event loop...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Stopping event loop...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Stopping Heart...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Stopping Tasks...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] Cancelling task consumer...
[2020-06-01 13:24:26,096: DEBUG/MainProcess] | Consumer: Stopping Control...
[2020-06-01 13:24:26,098: DEBUG/MainProcess] Closed channel #3
[2020-06-01 13:24:26,098: DEBUG/MainProcess] | Consumer: Stopping Mingle...
[2020-06-01 13:24:26,098: DEBUG/MainProcess] | Consumer: Stopping Gossip...
[2020-06-01 13:24:26,103: DEBUG/MainProcess] Closed channel #1
[2020-06-01 13:24:26,103: DEBUG/MainProcess] | Consumer: Stopping Events...
[2020-06-01 13:24:26,103: DEBUG/MainProcess] Closed channel #1
[2020-06-01 13:24:26,103: DEBUG/MainProcess] | Consumer: Stopping Connection...
[2020-06-01 13:24:26,103: DEBUG/MainProcess] | Worker: Stopping Pool...
[2020-06-01 13:24:26,604: ERROR/MainProcess] Error while stopping Pool: RuntimeError('Set changed size during iteration',)
Traceback (most recent call last):
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/__init__.py", line 208, in start
self.blueprint.start(self)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 127, in start
step.start(parent)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 378, in start
return self.obj.start()
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/consumer.py", line 271, in start
blueprint.start(self)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 127, in start
step.start(parent)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/consumer.py", line 766, in start
c.loop(*c.loop_args())
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/worker/loops.py", line 72, in asynloop
next(loop)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/kombu/async/hub.py", line 328, in create_loop
next(cb)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/concurrency/asynpool.py", line 186, in _recv_message
n = len(chunk)
UnboundLocalError: local variable 'chunk' referenced before assignment
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 160, in send_all
fun(parent, *args)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/bootsteps.py", line 382, in stop
return self.obj.stop()
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/concurrency/base.py", line 117, in stop
self.on_stop()
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/concurrency/prefork.py", line 148, in on_stop
self._pool.join()
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/billiard/pool.py", line 1532, in join
stop_if_not_current(self._result_handler)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/billiard/pool.py", line 151, in stop_if_not_current
thread.stop(timeout)
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/billiard/pool.py", line 500, in stop
self.on_stop_not_started()
File "/home/py/.virtualenvs/ai/lib/python3.6/site-packages/celery/concurrency/asynpool.py", line 245, in on_stop_not_started
for fd in outqueues:
RuntimeError: Set changed size during iteration
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/48321.html
標籤:其他技術討論專區
上一篇:設計模式如何學習
下一篇:復制粘貼問題求助!!!
