Объект коллекции Pymongo терпит неудачу, когда я пытаюсь запустить свои задачи с сельдереем. Я предполагаю, что он не мог сериализовать это. Что я должен делать? Кстати, я пробовал рассол, но он мне не помогает.
PS: я не хочу делать глобальный импорт базы данных в этот модуль.
Объект «Коллекция» не вызывается. Если вы хотели вызвать метод 'getnewargs'....
Пример кода ниже. module.py
from celery.contrib.methods import task_method
class Some_Class(object):
"""docstring for Some_Class"""
def __init__(self, db):
super(Some_Class, self).__init__()
self.db = db # This object causes 'Collection' object is not callable
#db is a pymongo collection object from db.py
@app.task(filter=task_method) # Celery task
def add(self):
"""
db.insert({'some_key':'some_value'})
"""
return 3
db.py
from pymongo import MongoClient
db = MongoClient()['test']['collection']
dill.detect
. github.com/uqfoundation - person Mike McKerns   schedule 23.12.2014