Обектът за събиране на Pymongo се проваля, когато се опитвам да изпълня задачите си с целина. Предполагам, че не може да го сериализира. Какво трябва да направя? Между другото опитах туршия, но не ми помогна.
PS: Не искам да правя глобален db импорт към този модул.
Обектът „Колекция“ не може да бъде извикан. Ако сте искали да извикате метода „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