Celery提交任务出错?

发布于 2022-09-06 11:31:34 字数 1622 浏览 15 评论 0

跟着官方的入门教程部署和运行的,为啥报这个错?

tasks.py

# -*- encoding:UTF-8 -*-

from celery import Celery

brokers = 'redis://localhost:6379'
backend = 'redis://localhost:6379'

app = Celery('tasks', broker=brokers, backend=backend)
app.control.purge()


@app.task
def add(x, y):
    return x + y

clipboard.png

>>> from tasks import add
>>> add.delay(6,6)
<AsyncResult: e1b8521e-e8a1-4431-8232-b0cbe7a35e9e>
[2017-08-08 19:14:32,580: ERROR/MainProcess] Task handler raised error: ValueErr
or('not enough values to unpack (expected 3, got 0)',)
Traceback (most recent call last):
  File "c:\python352\lib\site-packages\billiard\pool.py", line 358, in workloop
    result = (True, prepare_result(fun(*args, **kwargs)))
  File "c:\python352\lib\site-packages\celery\app\trace.py", line 525, in _fast_
trace_task
    tasks, accept, hostname = _loc
ValueError: not enough values to unpack (expected 3, got 0)
[2017-08-08 19:15:46,049: ERROR/MainProcess] Task handler raised error: ValueErr
or('not enough values to unpack (expected 3, got 0)',)
Traceback (most recent call last):
  File "c:\python352\lib\site-packages\billiard\pool.py", line 358, in workloop
    result = (True, prepare_result(fun(*args, **kwargs)))
  File "c:\python352\lib\site-packages\celery\app\trace.py", line 525, in _fast_
trace_task
    tasks, accept, hostname = _loc
ValueError: not enough values to unpack (expected 3, got 0)

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(4

¢好甜 2022-09-13 11:31:34

celery可能需要个低版本,换下4.1.0为3.1.24试下。
https://github.com/celery/cel...

宛菡 2022-09-13 11:31:34

celery -A your_app_name worker --pool=solo -l info 换这个试试

书间行客 2022-09-13 11:31:34

我也出现这个错误了 ,楼主是怎么解决的 真是版本问题么

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文