Skip to content

Commit 96f8fb3

Browse files
More logging
1 parent 292b5f1 commit 96f8fb3

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/replit_river/v2/session.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -293,11 +293,11 @@ def unbind_connecting_task() -> None:
293293
# This is safe because each individual function that is waiting on this
294294
# function completeing already has a reference, so we'll last a few ticks
295295
# before GC.
296-
#
297-
# Let's do our best to avoid clobbering other tasks by comparing the .name
298296
current_task = asyncio.current_task()
299297
if self._connecting_task is current_task:
300298
self._connecting_task = None
299+
else:
300+
logger.debug("unbind_connecting_task failed, id did not match")
301301

302302
if not self._connecting_task:
303303
self._connecting_task = asyncio.create_task(
@@ -1213,6 +1213,7 @@ async def websocket_closed_callback() -> None:
12131213
ws = None
12141214
last_error = e
12151215
await asyncio.sleep(backoff_time / 1000)
1216+
logger.debug("Here, about to retry")
12161217
unbind_connecting_task()
12171218

12181219
if last_error is not None:

0 commit comments

Comments
 (0)