У нас есть простая программа сельдерея, которая создает группу и сохраняет результат группы в бэкэнд. Мы делаем это для того, чтобы в будущем мы могли восстановить группу и проверить результаты.
Похоже, CassandraBackend не поддерживает этот тип сохранения и восстановления. Ранее мы использовали Redis, и там все работало нормально.
Мы уже пробовали просматривать CassandraBackend, и кажется, что метод _save_group
не реализован
job = group_sig.delay()
job.save(backend=tasks.cel.backend)
Мы получаем следующую трассировку стека:
job.save(backend=tasks.cel.backend)
File "/Users/shaunak/instabase-repo/instabase/venv/lib/python2.7/site-packages/celery/result.py", line 887, in save
return (backend or self.app.backend).save_group(self.id, self)
File "/Users/shaunak/instabase-repo/instabase/venv/lib/python2.7/site-packages/celery/backends/base.py", line 399, in save_group
return self._save_group(group_id, result)
AttributeError: 'CassandraBackend' object has no attribute '_save_group'
Я не уверен, что мы поступаем правильно, поэтому просто хотел проверить.