Explorar o código

Manual pick of fix for #2580 into 3.1 branch

Ask Solem %!s(int64=10) %!d(string=hai) anos
pai
achega
8572beecce
Modificáronse 1 ficheiros con 5 adicións e 2 borrados
  1. 5 2
      celery/backends/mongodb.py

+ 5 - 2
celery/backends/mongodb.py

@@ -92,8 +92,11 @@ class MongoBackend(BaseBackend):
             self.options = dict(config, **config.pop('options', None) or {})
 
             # Set option defaults
-            self.options.setdefault('max_pool_size', self.max_pool_size)
-            self.options.setdefault('auto_start_request', False)
+            if pymongo.version_tuple >= (3, ):
+                self.options.setdefault('maxPoolSize', self.max_pool_size)
+            else:
+                self.options.setdefault('max_pool_size', self.max_pool_size)
+                self.options.setdefault('auto_start_request', False)
 
         self.url = url
         if self.url: