diff --git a/celery/backends/mongodb.py b/celery/backends/mongodb.py index 9756afb34b..ef1a97c47b 100644 --- a/celery/backends/mongodb.py +++ b/celery/backends/mongodb.py @@ -92,8 +92,11 @@ def __init__(self, app=None, url=None, **kwargs): 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: