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