Method run

marimo/_session/state/serialize.py:461–485

(self)

            raise

    async def run(self) -> None:
        while self.running:
            try:
                if self.session_view.needs_export("session"):
                    self.session_view.mark_auto_export_session()
                    LOGGER.debug(f"Writing session view to cache {self.path}")
                    data = serialize_session_view(
                        self.session_view,
                        cell_ids=self.document.cell_ids,
                        script_metadata_hash=_script_metadata_hash(
                            self.notebook_path
                        ),
                        drop_virtual_file_outputs=True,
                    )
                    if isinstance(self.path, AsyncPath):
                        await self.path.write_text(json.dumps(data, indent=2))
                    else:
                        self.path.write_text(json.dumps(data, indent=2))
                await asyncio.sleep(self.interval)
            except asyncio.CancelledError:
                raise
            except Exception as e:
                LOGGER.error(f"Write error: {e}")
                # If we fail to write, we should stop the writer
                break


@dataclass