Closed lijiang2014 closed 7 years ago
新版本的celery 似乎有些地方需要进行比较严谨的处理
经常性偶发错误,无法判断其具体原因,见于自动提交模式。手动调试模式则不会出现此错误。很奇怪的问题。。即使只返回 int 也会出错,估计是由于无法正确的处理 Exception 对象 导致的 。
现在不想去深究原因,强制指定 Celery 使用 V3 时的序列化方式:
1 ht_celery/celery.py
@@ -26,6 +26,7 @@
app.conf.update(
result_expires = 3600 ,
+ result_serializer = "pickle" ,
)
if __name__ == '__main__':
kombu.exceptions.DecodeError: invalid load key, '{'.