Windows系统下Celery任务处理崩溃问题求助

问题场景 #

在Windows系统中调用Celery任务时出现崩溃，执行代码如下：

>>> from tasks import sum_task
>>> result = sum_task.delay(4, 5)   # 简单的数字求和函数

报错信息 #

执行后Celery崩溃，报错日志：

[2024-10-03 23:27:32,854: DEBUG/MainProcess] TaskPool: Apply <function fast_trace_task at 0x0000020330335310> (args:('tasks.sum_task', '8fcfe22c-12e2-420c-af1b-2fe830acf23d', {'argsrepr': '(4, 33)', 'eta': None, 'expires': None, 'group': None, 'group_index': None, 'id': '8fcfe22c-12e2-420c-af1b-2fe830acf23d', 'ignore_result': False, 'kwargsrepr': '{}', 'lang': 'py', 'origin': 'gen80336@DominicRazer', 'parent_id': None, 'replaced_task_nesting': 0, 'retries': 0, 'root_id': '8fcfe22c-12e2-420c-af1b-2fe830acf23d', 'shadow': None, 'stamped_headers': None, 'stamps': {}, 'task': 'tasks.sum_task', 'timelimit': [None, None], 'properties': {'content_type': 'application/json', 'content_encoding': 'utf-8', 'application_headers': {'argsrepr': '(4, 33)', 'eta': None, 'expires': None, 'group': None, 'group_index': None, 'id': '8fcfe22c-12e2-420c-af1b-2fe830acf23d', 'ignore_result': False, 'kwargsrepr': '{}', 'lang': 'py', 'origin': 'gen80336@DominicRazer', 'parent_id': None, 'replaced_task_nesting': 0, 'retries': 0, 'root_id': '8fcfe22c-12e2-420c-af1b-2fe830acf23d', 'shadow': None, 'stamped_headers': None, 'stamps': {}, 'task':... kwargs:{})
[2024-10-03 23:27:32,868: ERROR/MainProcess] Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)')
billiard.einfo.RemoteTraceback:
"""
Traceback (most recent call last):
  File "C:\Users\xxxx\.conda\envs\celery_demo\lib\site-packages\billiard\pool.py", line 362, in workloop
    result = (True, prepare_result(fun(args, **kwargs)))
  File "C:\Users\xxxx\.conda\envs\celery_demo\lib\site-packages\celery\app\trace.py", line 664, in fast_trace_task
    tasks, accept, hostname = _loc
ValueError: not enough values to unpack (expected 3, got 0)
"""

已尝试方案 #

咨询过Claude 3.5 Sonnet和GPT-4o，问题仍未解决，寻求技术支持。

内容的提问来源于stack exchange，提问作者Dominic Dawes