Skip to content

Commit 8ce9d7f

Browse files
committed
fix typing
1 parent 3442866 commit 8ce9d7f

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

pymongo/asynchronous/client_session.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -713,12 +713,13 @@ async def callback(session, custom_arg, custom_kwarg=None):
713713
"""
714714
start_time = time.monotonic()
715715
retry = 0
716-
last_error = None
716+
last_error: Optional[BaseException] = None
717717
while True:
718718
if retry: # Implement exponential backoff on retry.
719719
jitter = random.random() # noqa: S311
720720
backoff = jitter * min(_BACKOFF_INITIAL * (1.25**retry), _BACKOFF_MAX)
721721
if _would_exceed_time_limit(start_time, backoff):
722+
assert last_error is not None
722723
raise last_error
723724
await asyncio.sleep(backoff)
724725
retry += 1

pymongo/synchronous/client_session.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -711,12 +711,13 @@ def callback(session, custom_arg, custom_kwarg=None):
711711
"""
712712
start_time = time.monotonic()
713713
retry = 0
714-
last_error = None
714+
last_error: Optional[BaseException] = None
715715
while True:
716716
if retry: # Implement exponential backoff on retry.
717717
jitter = random.random() # noqa: S311
718718
backoff = jitter * min(_BACKOFF_INITIAL * (1.25**retry), _BACKOFF_MAX)
719719
if _would_exceed_time_limit(start_time, backoff):
720+
assert last_error is not None
720721
raise last_error
721722
time.sleep(backoff)
722723
retry += 1

0 commit comments

Comments
 (0)