(self)
| 291 | self.state.snapshot = _MarkerSnapshot(id="marker") |
| 292 | |
| 293 | async def stop(self) -> None: |
| 294 | self.stop_calls += 1 |
| 295 | self._running = False |
| 296 | await self._stop_gate.wait() |
| 297 | snapshot = cast(_MarkerSnapshot, self.state.snapshot) |
| 298 | self.state.snapshot = snapshot.model_copy(update={"marker": "persisted"}) |
| 299 | |
| 300 | |
| 301 | class _ProvisioningFailureSession(_FakeSession): |