|
@@ -21,15 +21,12 @@ class Bunch:
|
|
|
|
|
|
|
|
|
class MongoBackend(BaseDictBackend):
|
|
|
-
|
|
|
- capabilities = ["ResultStore"]
|
|
|
-
|
|
|
- mongodb_host = 'localhost'
|
|
|
+ mongodb_host = "localhost"
|
|
|
mongodb_port = 27017
|
|
|
mongodb_user = None
|
|
|
mongodb_password = None
|
|
|
- mongodb_database = 'celery'
|
|
|
- mongodb_taskmeta_collection = 'celery_taskmeta'
|
|
|
+ mongodb_database = "celery"
|
|
|
+ mongodb_taskmeta_collection = "celery_taskmeta"
|
|
|
|
|
|
def __init__(self, *args, **kwargs):
|
|
|
"""Initialize MongoDB backend instance.
|
|
@@ -52,15 +49,15 @@ class MongoBackend(BaseDictBackend):
|
|
|
raise ImproperlyConfigured(
|
|
|
"MongoDB backend settings should be grouped in a dict")
|
|
|
|
|
|
- self.mongodb_host = config.get('host', self.mongodb_host)
|
|
|
- self.mongodb_port = int(config.get('port', self.mongodb_port))
|
|
|
- self.mongodb_user = config.get('user', self.mongodb_user)
|
|
|
+ self.mongodb_host = config.get("host", self.mongodb_host)
|
|
|
+ self.mongodb_port = int(config.get("port", self.mongodb_port))
|
|
|
+ self.mongodb_user = config.get("user", self.mongodb_user)
|
|
|
self.mongodb_password = config.get(
|
|
|
- 'password', self.mongodb_password)
|
|
|
+ "password", self.mongodb_password)
|
|
|
self.mongodb_database = config.get(
|
|
|
- 'database', self.mongodb_database)
|
|
|
+ "database", self.mongodb_database)
|
|
|
self.mongodb_taskmeta_collection = config.get(
|
|
|
- 'taskmeta_collection', self.mongodb_taskmeta_collection)
|
|
|
+ "taskmeta_collection", self.mongodb_taskmeta_collection)
|
|
|
|
|
|
super(MongoBackend, self).__init__(*args, **kwargs)
|
|
|
self._connection = None
|