<p>我使用芹菜和弦来构造大型文档页面内容的并行AI处理。因为这是一个没有公共签名的一次性函数,所以我正在清理对象以进行分发和重新聚合。处理单个页面的任务是成功读取参数并执行所需的函数。但是,它尝试将结果返回到队列以进行后续聚合时失败</p>
<p>有人知道为一个名为via Chord的任务指定结果序列化程序的方法吗</p>
<p>和弦生成--</p>
<pre><code>callback = processPageResults.subtask(kwargs={'cdd_id' : cdoc.cdd_id,'user_id':user.id},options={'serializer':'pickle'})
res = chord([processPage.s(useBold,
docPages[i]).set(serializer='pickle') for i in range(0, len(docPages))], callback)()
</code></pre>
<p>调用任务---
@共享任务(序列化程序='pickle',结果序列化程序='pickle',bind=True,最大重试次数=20次)
def processPage(自身,*参数):
useBold=args[0]
page=args[1]
page.processWords(使用粗体)
返回页</p>
<p>错误--</p>
<pre><code>kombu.exceptions.EncodeError: Object of type DocumentPage is not JSON serializable
</code></pre>