Use YStore's start_lock

davidbrochart · May 7, 2024 · 24e8c18 · 24e8c18
1 parent 85c5220
commit 24e8c18
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/jupyter_collaboration/rooms.py b/jupyter_collaboration/rooms.py
@@ -103,9 +103,10 @@ async def initialize(self) -> None:
             # try to apply Y updates from the YStore for this document
             read_from_source = True
             if self.ystore is not None:
-                if not self.ystore.started.is_set():
-                    self.create_task(self.ystore.start())
-                    await self.ystore.started.wait()
+                async with self.ystore.start_lock:
+                    if not self.ystore.started.is_set():
+                        self.create_task(self.ystore.start())
+                        await self.ystore.started.wait()
                 try:
                     await self.ystore.apply_updates(self.ydoc)
                     self._emit(