Я пытаюсь выполнить некоторые операции над объектом pymongo Cursor и объектом pymongo Collection в сельдерее.Мой рабочий определяется следующим образом:
@app.task
def find_missing_songs(cursor_object, collection_object):
# Some operation is performed on both arguments
Вот как я вызываю определенную выше функцию:
from bson.json_util import dumps
find_missing_songs.delay(dumps(cursor_object), dumps(collection_object))
Я прочитал, что dumps может быть полезным для сериализации Cursorобъекты.Тем не менее, я получаю следующую ошибку для Collection объекта:
TypeError: 'Collection' object is not callable. If you meant to call the 'iteritems' method on a 'Collection' object it is failing because no such method exists.
Есть ли способ, которым Collection объект может быть сериализован?