Skip to content

Commit ce493e4

Browse files
committed
SH review
1 parent af54ac3 commit ce493e4

2 files changed

Lines changed: 8 additions & 6 deletions

File tree

pymongo/asynchronous/mongo_client.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -894,15 +894,16 @@ def __init__(
894894
self._options.read_concern,
895895
)
896896

897+
self._retry_policy = _RetryPolicy(
898+
_TokenBucket(), adaptive_retry=self._options.adaptive_retries
899+
)
900+
897901
self._init_based_on_options(self._seeds, srv_max_hosts, srv_service_name)
898902

899903
self._opened = False
900904
self._closed = False
901905
self._loop: Optional[asyncio.AbstractEventLoop] = None
902906

903-
self._retry_policy = _RetryPolicy(
904-
_TokenBucket(), adaptive_retry=self._options.adaptive_retries
905-
)
906907
if not is_srv:
907908
self._init_background()
908909

pymongo/synchronous/mongo_client.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -894,15 +894,16 @@ def __init__(
894894
self._options.read_concern,
895895
)
896896

897+
self._retry_policy = _RetryPolicy(
898+
_TokenBucket(), adaptive_retry=self._options.adaptive_retries
899+
)
900+
897901
self._init_based_on_options(self._seeds, srv_max_hosts, srv_service_name)
898902

899903
self._opened = False
900904
self._closed = False
901905
self._loop: Optional[asyncio.AbstractEventLoop] = None
902906

903-
self._retry_policy = _RetryPolicy(
904-
_TokenBucket(), adaptive_retry=self._options.adaptive_retries
905-
)
906907
if not is_srv:
907908
self._init_background()
908909

0 commit comments

Comments
 (0)