diff --git a/celery/backends/mongodb.py b/celery/backends/mongodb.py index 624807aadd..278eb6496c 100644 --- a/celery/backends/mongodb.py +++ b/celery/backends/mongodb.py @@ -79,6 +79,14 @@ def __init__(self, app=None, url=None, **kwargs): self.url = url + # default options according to pymongo version + 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) + + # update conf with mongo uri data, only if uri was given if self.url: uri_data = pymongo.uri_parser.parse_uri(self.url)