芹菜和弦因valueerror的失败：没有足够的价值打开包装（预期2，得到1）

Question

我正在运行 ubuntu 的 docker 容器中运行 celery v5.2.3。

在这里，我试图让芹菜和弦发挥作用，但我所做的每一次尝试都会给我带来：

    File "/usr/local/lib/python3.7/site-packages/celery/result.py", line 1056, in result_from_tuple
    res, nodes = r
ValueError: not enough values to unpack (expected 2, got 1)

出现此错误后，和弦会不断重试：

retry: Retry in 1.0s: ValueError('not enough values to unpack (expected 2, got 1)')

我尝试运行的任务如下：

@celery_app.task(shared=False)
def add(x, y):
    return x + y


@celery_app.task(shared=False)
def tsum(numbers):
    return numbers

@celery_app.task(name="celery.test")
def test():
    x = chord([add.s(i, i) for i in range(10)], body=tsum.s())
    r = x.apply_async()
    r.get()

我的示例运行了 9/10 次迭代，但随后失败。

芹菜工人正在运行：

celery -A scheduler worker -P eventlet -l info 

你们谁能告诉我我做错了什么，因为我在互联网上找不到任何解释这个问题的东西？

Answer 1

对于未来任何不幸的人来说，都会遇到这个问题。

这个问题是因为我们为 celery 定制了 mongo 后端。
在这里，我们为任务定义了元字段，如下所示：

meta = {
            "_id": task_id,
            "status": status,
            "result": result,
            "date_done": datetime.utcnow(),
            "traceback": traceback,
            "children": self.encode(
                self.current_task_children(request),
            ),
            "task_name": task_name,
            "task_args": task_args,
            "task_kwargs": task_kwargs,
            "worker": worker,
        }

但是，由于 celery 期望孩子字段是孩子列表或无，我的问题是因为孩子字段总是由空列表填充。

通过将孩子改为：

"children": self.encode(
    self.current_task_children(request),
)
if len(self.current_task_children(request)) > 0
else None,

问题就可以解决。

如果有人经历过这个，我希望这会有所帮助