Celery Chord调用间歇性报错：'DisabledBackend'无'_restore_group'属性

核心问题原因 #

你遇到的GroupResult.restore间歇性报错，结合代码和Redis后端特性，主要由以下几个问题导致：

• Group元数据提前过期：Redis作为Celery后端时，group任务的元数据默认有过期时间。如果group内任务执行耗时较长，或者Redis的key过期配置过短，当chord回调触发时，group的ID对应的元数据已经被Redis自动清理，导致restore失败。

• Group实例未提前持久化：代码中直接用生成器创建group传入chord，没有提前将group的元数据保存到后端。当chord的回调需要恢复group结果时，可能无法找到对应的元数据，尤其是在分布式环境下，不同worker节点的缓存不一致时更容易触发。

• 任务参数不匹配：xyz和ijk任务定义需要a、b两个参数，但创建signature时传入的kwargs={}是空的，这会导致任务执行时参数缺失报错，进而干扰chord的状态流转，间接引发restore异常。

• 语法错误：apply_async(queue="ocr-queue2"})多了一个右大括号，这会直接导致任务提交失败，虽然你描述是间歇性报错，但这个笔误必须修正。

修复方案 #

1. 调整Redis后端的group过期时间
   在Celery配置中增加或修改以下参数（根据Celery版本选择，新版本用task_group_expires，旧版本用CELERY_GROUP_EXPIRES），延长group元数据的保存时间：

# 示例：设置为24小时（单位：秒）
CELERY_GROUP_EXPIRES = 86400
# 或新版本
task_group_expires = 86400

2. 提前创建并持久化Group实例
   修改abcd任务的代码，先实例化group并保存元数据，再传入chord：

@CELERY.task(bind=True, name='abcd')
def abcd(self):
    # 确保y是可迭代对象，且每个x能生成对应的a、b参数
    group_tasks = group(
        CELERY.signature('xyz', kwargs={'a': x['a'], 'b': x['b']}) for x in y
    )
    # 先提交group任务并保存元数据
    group_result = group_tasks.apply_async(queue="ocr-queue2")
    group_result.save()
    
    # 创建chord时使用已保存的group结果
    jobs = chord(
        group_result,
        CELERY.signature('ijk', immutable=True, kwargs={'a': some_val, 'b': another_val})
    )
    chord_result = jobs.apply_async(queue="ocr-queue2")
    chord_result.save()

3. 修正任务参数
   创建signature时必须传入任务所需的a、b参数，避免任务执行失败影响chord流程。

4. 修复语法错误
   将apply_async(queue="ocr-queue2"})修正为apply_async(queue="ocr-queue2")。

内容的提问来源于stack exchange，提问作者Chaitu. Petluri