(next_audit: dict[str, Any] | None = None)
| 395 | was_cancelled = False |
| 396 | |
| 397 | async def persist_terminal_audit(next_audit: dict[str, Any] | None = None) -> None: |
| 398 | if not diagram_state_repository.is_configured(): |
| 399 | return |
| 400 | try: |
| 401 | await asyncio.to_thread( |
| 402 | diagram_state_repository.persist_terminal_session_audit, |
| 403 | username=parsed.username, |
| 404 | repo=parsed.repo, |
| 405 | audit=next_audit or audit, |
| 406 | visibility=storage_visibility, |
| 407 | github_pat=parsed.github_pat, |
| 408 | ) |
| 409 | except Exception as exc: |
| 410 | log_event( |
| 411 | "generate.persistence.audit_failed", |
| 412 | username=parsed.username, |
| 413 | repo=parsed.repo, |
| 414 | session_id=audit["sessionId"], |
| 415 | error=str(exc), |
| 416 | ) |
| 417 | |
| 418 | async def persist_successful_state( |
| 419 | *, |
no test coverage detected