Skip to content

Commit 511c5ca

Browse files
Actually assign terminating_task
1 parent 177cf27 commit 511c5ca

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/replit_river/v2/session.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -509,7 +509,8 @@ async def do_close() -> None:
509509
if self._terminating_task:
510510
return self._terminating_task
511511

512-
return asyncio.create_task(do_close())
512+
self._terminating_task = asyncio.create_task(do_close())
513+
return self._terminating_task
513514

514515
def _start_buffered_message_sender(
515516
self,

0 commit comments

Comments
 (0)