File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff 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
Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments