CassandraBackend не имеет атрибута save_group - PullRequest
0 голосов
/ 23 мая 2019

У нас есть простая программа сельдерея, которая создает группу и сохраняет результат группы в бэкэнд. Мы делаем это для того, чтобы в будущем мы могли восстановить группу и проверить результаты.

Похоже, 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'

Я не уверен, что мы поступаем правильно, поэтому просто хотел проверить.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...