@@ -215,7 +215,7 @@ async def open(self, room_id):
215
215
216
216
self ._emit (LogLevel .INFO , "initialize" , "New client connected." )
217
217
else :
218
- if self .room . room_id != "JupyterLab:globalAwareness" :
218
+ if self ._room_id != "JupyterLab:globalAwareness" :
219
219
self ._emit_awareness_event (self .current_user .username , "join" )
220
220
221
221
async def send (self , message ):
@@ -296,7 +296,7 @@ def on_close(self) -> None:
296
296
# keep the document for a while in case someone reconnects
297
297
self .log .info ("Cleaning room: %s" , self ._room_id )
298
298
self .room .cleaner = asyncio .create_task (self ._clean_room ())
299
- if self .room . room_id != "JupyterLab:globalAwareness" :
299
+ if self ._room_id != "JupyterLab:globalAwareness" :
300
300
self ._emit_awareness_event (self .current_user .username , "leave" )
301
301
302
302
def _emit (self , level : LogLevel , action : str | None = None , msg : str | None = None ) -> None :
@@ -339,7 +339,7 @@ async def _clean_room(self) -> None:
339
339
340
340
async with self ._room_lock (self ._room_id ):
341
341
# Remove the room from the websocket server
342
- self .log .info ("Deleting Y document from memory: %s" , self .room . room_id )
342
+ self .log .info ("Deleting Y document from memory: %s" , self ._room_id )
343
343
self ._websocket_server .delete_room (room = self .room )
344
344
345
345
# Clean room
0 commit comments