-
-
Notifications
You must be signed in to change notification settings - Fork 983
Closed
Description
The pymongo parser is used here and it converts timeouts values (ex. sockettimeoutms) from ms into seconds.
kombu/kombu/transport/mongodb.py
Line 308 in 0411b23
| parsed = uri_parser.parse_uri(hostname, port) |
Then these parameters are passed as keywords argument into __init__ method of MongoClient, but there is another iteration of converting arguments:
As a result timeout arguments, which are passed through connection URI, are double divided and we get timeouts 0.01 seconds instead of 10 for example.
The simpliest solution is to add `validate=False when parsing uri on the kombu side:
parsed = uri_parser.parse_uri(hostname, port, validate=False)Disadvantage of this approach that transport may retry establishing connection with incorrectly passed configuration, while client will raise an Exception
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels