Fix celery#5734 Celery does not consider authMechanism on mongodb bac…

…kend URLs
spengjie · Oct 25, 2019 · f36337a · f36337a
1 parent ca83e25
commit f36337a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/celery/backends/mongodb.py b/celery/backends/mongodb.py
@@ -157,6 +157,10 @@ def _get_connection(self):
             # don't change self.options
             conf = dict(self.options)
             conf['host'] = host
+            if self.user:
+                conf['username'] = self.user
+            if self.password:
+                conf['password'] = self.password
 
             self._connection = MongoClient(**conf)