From a5c44c4ac02d5f033a95ed9e1c072fb6a5a25ddc Mon Sep 17 00:00:00 2001 From: KiriAky 107 Date: Sun, 6 Sep 2026 02:57:56 +0800 Subject: [PATCH] fix(workspace): background vector indexing and correct diagram previews --- backend/app/contracts.py | 1 + backend/app/main.py | 2 + backend/app/routes.py | 2 +- backend/app/services/index_service.py | 183 ++++++++++++++---- backend/app/services/note_service.py | 24 ++- backend/app/services/workspace_service.py | 40 +++- backend/tests/test_workspace_background.py | 131 +++++++++++++ frontend/src/components/common/AppShell.vue | 12 +- .../common/DiagramInteractions.spec.ts | 56 ++++++ .../components/common/DiagramInteractions.vue | 62 +++++- frontend/src/components/common/StatusBar.vue | 3 +- frontend/src/contracts/index.ts | 2 + .../features/editor/VisualMarkdownEditor.vue | 3 + frontend/src/features/vault/VaultEntry.vue | 36 ++-- frontend/src/services/apiClient.spec.ts | 26 +++ frontend/src/services/apiClient.ts | 14 +- frontend/src/services/indexService.ts | 3 +- frontend/src/services/systemService.ts | 6 +- frontend/src/services/workspaceService.ts | 4 +- frontend/src/stores/editor.ts | 1 + frontend/src/stores/editorSave.spec.ts | 25 +++ 21 files changed, 561 insertions(+), 75 deletions(-) create mode 100644 backend/tests/test_workspace_background.py create mode 100644 frontend/src/services/apiClient.spec.ts create mode 100644 frontend/src/stores/editorSave.spec.ts diff --git a/backend/app/contracts.py b/backend/app/contracts.py index a2236da..a7b4f6f 100644 --- a/backend/app/contracts.py +++ b/backend/app/contracts.py @@ -1131,6 +1131,7 @@ class TranscriptNoteRequest(Contract): class IndexStatus(Contract): + vector_refresh_required: bool = False total_notes: int = 0 total_blocks: int = 0 status: Literal["idle", "queued", "running", "failed"] = "idle" diff --git a/backend/app/main.py b/backend/app/main.py index d307982..8320078 100644 --- a/backend/app/main.py +++ b/backend/app/main.py @@ -25,6 +25,8 @@ async def lifespan(_: FastAPI): try: yield finally: + from app.services import index_service + await index_service.shutdown() await transcription_service.shutdown() from app.local_models import components await components.shutdown() diff --git a/backend/app/routes.py b/backend/app/routes.py index 8211bc0..2cd285d 100644 --- a/backend/app/routes.py +++ b/backend/app/routes.py @@ -286,7 +286,7 @@ async def get_note(note_id: str) -> Note: @router.patch("/notes/{note_id}", response_model=Note, tags=["Notes"]) async def update_note(note_id: str, request: NoteUpdateRequest) -> Note: return await note_service.update_note( - note_id, title=request.title, markdown=request.markdown, tags=request.tags + note_id, title=request.title, markdown=request.markdown, tags=request.tags, defer_vectors=True ) diff --git a/backend/app/services/index_service.py b/backend/app/services/index_service.py index 4c72c92..947153d 100644 --- a/backend/app/services/index_service.py +++ b/backend/app/services/index_service.py @@ -1,11 +1,10 @@ -"""索引服务：扫描 Vault、全量重建索引、查询索引状态。 - -MVP 阶段重建是同步的（数据量小），完成后直接返回 completed 的 IndexJob。 -索引任务暂存内存（_jobs），不持久化到 SQLite；后续接入异步任务队列时再落到 index_jobs 表。 -""" +"""索引服务：后台重建、快照校验与原子替换，不在模型计算期间锁住笔记编辑。""" from __future__ import annotations +import asyncio +import logging + from datetime import datetime, timezone from pathlib import Path from uuid import uuid4 @@ -17,7 +16,7 @@ from app.errors import ApiError from app.knowledge.parser import parse_note from app.services.note_service import index_note, prepare_note_index from app.database.db import connect, transaction -from app.services.coordination import serialized_vault_mutation +from app.services.coordination import _vault_mutation_lock from app.retrieval.vectorstore import SqliteVecStore from app.local_models.runtime import LocalEmbedding from app.services import note_service @@ -29,6 +28,8 @@ _active_job_id: str | None = None _last_completed_at: datetime | None = None _last_error: str | None = None MAX_JOBS = 100 +_background_task: asyncio.Task | None = None +_logger = logging.getLogger(__name__) def _remember_job(job: IndexJob) -> None: @@ -62,9 +63,10 @@ def _scan_vault() -> list[tuple[str, str, str, datetime, datetime]]: return result -@serialized_vault_mutation async def rebuild(request: IndexRebuildRequest) -> IndexJob: global _active_job_id, _last_completed_at, _last_error + if _active_job_id is not None: + raise ApiError(409, "INDEX_BUSY", "索引正在后台计算，请稍后重试。") job_id = "job_" + uuid4().hex[:12] # 增量重建（scope != all 或指定 note_ids）尚未实现，明确拒绝而非静默全量重建 if request.scope != "all" or request.note_ids: @@ -76,6 +78,8 @@ async def rebuild(request: IndexRebuildRequest) -> IndexJob: ) docs = _scan_vault() + saved_records = {key: repository.get_note_record(key) for key in _pending_notes()} + saved_paths = {record.file_path: record for record in saved_records.values() if record is not None} _active_job_id = job_id _last_error = None @@ -91,6 +95,10 @@ async def rebuild(request: IndexRebuildRequest) -> IndexJob: markdown=markdown, file_path=rel, folder=folder, tags=None, created_at=created, updated_at=updated, ) + if saved := saved_paths.get(rel): + parsed = parse_note(markdown=markdown, file_path=rel, folder=folder, tags=saved.tags, + created_at=saved.created_at, updated_at=saved.updated_at, note_id=saved.note_id) + parsed.title = saved.title prepared = await prepare_note_index(parsed, strict=True) if isinstance(note_service.embedding, LocalEmbedding) else await prepare_note_index(parsed) if isinstance(note_service.embedding, LocalEmbedding) and parsed.blocks: batch = prepared[1] @@ -104,37 +112,41 @@ async def rebuild(request: IndexRebuildRequest) -> IndexJob: prepared_notes.append((parsed, prepared)) # All network/model awaits precede the transaction. The concrete SQLite # methods below complete synchronously despite their async interfaces. - conn = connect() - try: - with transaction(conn): - task_note_links = dict(conn.execute( - "SELECT task_id, note_id FROM tasks WHERE note_id IS NOT NULL" - ).fetchall()) - media_links = conn.execute("SELECT job_id,revision,options_hash,note_id FROM media_notes").fetchall() - repository.clear_all(conn=conn) - await vector_store.clear(conn=conn) - for parsed, prepared in prepared_notes: - await index_note(parsed, prepared=prepared, conn=conn) - for policy, space in semantic_spaces.items(): - exists = conn.execute("SELECT 1 FROM sqlite_master WHERE type='table' AND name='routed_block_vectors'").fetchone() - missing = not exists or conn.execute( - "SELECT 1 FROM blocks b LEFT JOIN routed_block_vectors r " - "ON r.block_id=b.block_id AND r.space_id=? AND r.dimensions=? " - "WHERE b.embedding_local_only=? AND r.block_id IS NULL LIMIT 1", (*space, int(policy)), - ).fetchone() - if missing: - raise ApiError(500, "SEMANTIC_INDEX_WRITE_FAILED", "向量索引写入失败，原索引已保留，请检查数据库和磁盘状态。") - for task_id, note_id in task_note_links.items(): - conn.execute( - "UPDATE tasks SET note_id = ? WHERE task_id = ? " - "AND EXISTS (SELECT 1 FROM notes WHERE note_id = ?)", - (note_id, task_id, note_id), - ) - for link in media_links: - conn.execute("INSERT OR IGNORE INTO media_notes SELECT ?,?,?,? WHERE EXISTS (SELECT 1 FROM notes WHERE note_id=?)", - (*link, link["note_id"])) - finally: - conn.close() + async with _vault_mutation_lock: + if _scan_vault() != docs or saved_records != {key: repository.get_note_record(key) for key in _pending_notes()}: + raise ApiError(409, "INDEX_SNAPSHOT_CHANGED", "笔记在计算期间发生变化，稍后重新计算。") + conn = connect() + try: + with transaction(conn): + task_note_links = dict(conn.execute( + "SELECT task_id, note_id FROM tasks WHERE note_id IS NOT NULL" + ).fetchall()) + media_links = conn.execute("SELECT job_id,revision,options_hash,note_id FROM media_notes").fetchall() + repository.clear_all(conn=conn) + await vector_store.clear(conn=conn) + for parsed, prepared in prepared_notes: + await index_note(parsed, prepared=prepared, conn=conn) + for policy, space in semantic_spaces.items(): + exists = conn.execute("SELECT 1 FROM sqlite_master WHERE type='table' AND name='routed_block_vectors'").fetchone() + missing = not exists or conn.execute( + "SELECT 1 FROM blocks b LEFT JOIN routed_block_vectors r " + "ON r.block_id=b.block_id AND r.space_id=? AND r.dimensions=? " + "WHERE b.embedding_local_only=? AND r.block_id IS NULL LIMIT 1", (*space, int(policy)), + ).fetchone() + if missing: + raise ApiError(500, "SEMANTIC_INDEX_WRITE_FAILED", "向量索引写入失败，原索引已保留，请检查数据库和磁盘状态。") + for task_id, note_id in task_note_links.items(): + conn.execute( + "UPDATE tasks SET note_id = ? WHERE task_id = ? " + "AND EXISTS (SELECT 1 FROM notes WHERE note_id = ?)", + (note_id, task_id, note_id), + ) + for link in media_links: + conn.execute("INSERT OR IGNORE INTO media_notes SELECT ?,?,?,? WHERE EXISTS (SELECT 1 FROM notes WHERE note_id=?)", + (*link, link["note_id"])) + repository.set_index_meta({"workspace_vectors_pending": "0"}, conn=conn) + finally: + conn.close() except BaseException as exc: _remember_job(IndexJob( job_id=job_id, status="failed", scope=request.scope, @@ -148,15 +160,19 @@ async def rebuild(request: IndexRebuildRequest) -> IndexJob: job = IndexJob(job_id=job_id, status="completed", scope=request.scope, created_at=datetime.now(timezone.utc)) _remember_job(job) _last_completed_at = job.created_at + if _pending_notes(): + schedule_workspace_rebuild() return job def get_status() -> IndexStatus: counts = repository.stats() + vector_refresh_required = repository.get_index_meta().get('workspace_vectors_pending') == '1' or bool(_pending_notes()) if _active_job_id is not None: - return IndexStatus(status="running", pending_jobs=0, active_job_id=_active_job_id, + return IndexStatus(status="running", pending_jobs=0, active_job_id=_active_job_id, vector_refresh_required=vector_refresh_required, total_notes=counts["notes"], total_blocks=counts["blocks"]) return IndexStatus( + vector_refresh_required=vector_refresh_required, total_notes=counts["notes"], total_blocks=counts["blocks"], status="failed" if _last_error else "idle", pending_jobs=0, @@ -167,3 +183,92 @@ def get_status() -> IndexStatus: def get_job(job_id: str) -> IndexJob | None: return _jobs.get(job_id) + + +def schedule_workspace_rebuild() -> None: + """单进程去重；任务失败保留待重建标记，重新打开 Vault 可重试。""" + global _background_task + if _background_task is not None and not _background_task.done(): + return + if _active_job_id is not None: + return + async def run(): + while True: + try: + if repository.get_index_meta().get('workspace_vectors_pending') == '1': + await rebuild(IndexRebuildRequest()) + elif pending := _pending_notes(): + await _refresh_saved_note(pending[0]) + else: + return + except ApiError as exc: + if exc.code == 'INDEX_SNAPSHOT_CHANGED': + await asyncio.sleep(1) + continue + _logger.warning('Background index failed: %s', exc.code) + return + except Exception: + _logger.exception('Background index failed') + return + _background_task = asyncio.create_task(run(), name='workspace-vector-index') + + +async def shutdown() -> None: + global _background_task + if _background_task is not None: + _background_task.cancel() + await asyncio.gather(_background_task, return_exceptions=True) + _background_task = None + + +def _pending_notes() -> list[str]: + return [key.split(':', 1)[1] for key, value in repository.get_index_meta().items() + if key.startswith('note_vectors_pending:') and value == '1'] + + +async def _refresh_saved_note(note_id: str) -> None: + global _active_job_id, _last_error, _last_completed_at + record = repository.get_note_record(note_id) + key = f'note_vectors_pending:{note_id}' + if record is None: + repository.set_index_meta({key: '0'}) + return + markdown = note_service._read_markdown(record.file_path) + parsed = parse_note(markdown=markdown, file_path=record.file_path, folder=record.folder, + tags=record.tags, created_at=record.created_at, + updated_at=record.updated_at, note_id=note_id) + parsed.title = record.title + job_id = 'job_' + uuid4().hex[:12] + _active_job_id = job_id + _last_error = None + _remember_job(IndexJob(job_id=job_id, status='running', scope='all', created_at=datetime.now(timezone.utc))) + try: + prepared = await prepare_note_index(parsed, strict=True) + if isinstance(note_service.embedding, LocalEmbedding) and parsed.blocks and prepared[1] is None: + raise ApiError(503, "EMBEDDING_UNAVAILABLE", "笔记已保存，后台向量计算未完成。") + async with _vault_mutation_lock: + current = repository.get_note_record(note_id) + if current != record or note_service._read_markdown(record.file_path) != markdown: + # Another save or rename won the race; leave the durable queue entry intact. + return + conn = connect() + try: + with transaction(conn): + # Write only vectors: metadata and FTS already represent the saved revision. + vectors, remote = prepared + from app.retrieval.vectorstore import VectorRecord + from app.retrieval import routed_vectors + await vector_store.upsert([VectorRecord(id=b.block_id, vector=v) + for b, v in zip(parsed.blocks, vectors)], conn=conn) + routed_vectors.store_remote(conn, [b.block_id for b in parsed.blocks], remote) + repository.set_index_meta({key: '0'}, conn=conn) + finally: + conn.close() + _last_completed_at = datetime.now(timezone.utc) + _remember_job(IndexJob(job_id=job_id, status='completed', scope='all', created_at=_last_completed_at)) + except BaseException as exc: + _last_error = str(exc) or '后台向量计算已中断，笔记已保存。' + _remember_job(IndexJob(job_id=job_id, status='failed', scope='all', created_at=datetime.now(timezone.utc))) + raise + finally: + _active_job_id = None diff --git a/backend/app/services/note_service.py b/backend/app/services/note_service.py index efd9931..a025723 100644 --- a/backend/app/services/note_service.py +++ b/backend/app/services/note_service.py @@ -181,7 +181,7 @@ async def get_note(note_id: str) -> Note | None: @serialized_vault_mutation async def update_note( - note_id: str, *, title: str | None = None, markdown: str | None = None, tags: list[str] | None = None, expected_content_hash: str | None = None + note_id: str, *, title: str | None = None, markdown: str | None = None, tags: list[str] | None = None, expected_content_hash: str | None = None, defer_vectors: bool = False ) -> Note: record = repository.get_note_record(note_id) if record is None: @@ -207,10 +207,30 @@ async def update_note( if title is not None: parsed.title = title # 显式传入的 title 覆盖正文推导结果 - await index_note(parsed) + if defer_vectors: + conn = connect() + try: + with transaction(conn): + old_ids = repository.replace_note_metadata( + conn=conn, note_id=parsed.note_id, title=parsed.title, + file_path=parsed.file_path, folder=parsed.folder, tags=parsed.tags, + created_at=parsed.created_at, updated_at=parsed.updated_at, blocks=parsed.blocks, + ) + # Saved content is immediately searchable; old vectors must not describe it. + await vector_store.delete(old_ids, conn=conn) + conn.execute('UPDATE blocks SET embedding_local_only=? WHERE note_id=?', + (int(parsed.embedding_local_only), parsed.note_id)) + repository.set_index_meta({f'note_vectors_pending:{parsed.note_id}': '1'}, conn=conn) + finally: + conn.close() + else: + await index_note(parsed) except BaseException: _write_markdown(record.file_path, old_md) # 索引失败时回滚正文，避免部分提交 raise + if defer_vectors: + from app.services import index_service + index_service.schedule_workspace_rebuild() return _build_note(parsed.note_id, parsed.title, parsed.file_path, parsed.tags, parsed.created_at, parsed.updated_at, parsed.blocks, new_md) diff --git a/backend/app/services/workspace_service.py b/backend/app/services/workspace_service.py index 6725a58..402885d 100644 --- a/backend/app/services/workspace_service.py +++ b/backend/app/services/workspace_service.py @@ -11,7 +11,6 @@ from uuid import uuid4 from app import repository from app.config import get_settings from app.contracts import ( - IndexRebuildRequest, OperationResponse, WorkspaceEntry, WorkspaceInfo, @@ -20,6 +19,7 @@ from app.contracts import ( from app.database.db import connect, transaction from app.errors import ApiError from app.retrieval.vectorstore import SqliteVecStore +from app.knowledge.parser import parse_note from app.services import index_service from app.services.coordination import serialized_vault_mutation from app.services.vault_paths import normalize_entry_name, normalize_folder, resolve_in_vault @@ -106,7 +106,7 @@ def get_workspace_tree() -> list[WorkspaceEntry]: async def open_workspace(requested_path: str | None) -> WorkspaceSnapshot: - """打开当前配置 Vault；发现未索引文件时先执行一次安全全量刷新。""" + """打开只登记文件与全文索引，不让 Embedding 或厂商网络阻塞工作区。""" root = get_settings().vault_path.resolve() if requested_path and Path(requested_path).resolve() != root: @@ -119,11 +119,45 @@ async def open_workspace(requested_path: str | None) -> WorkspaceSnapshot: root.mkdir(parents=True, exist_ok=True) info = get_workspace_info() if info.requires_refresh: - await index_service.rebuild(IndexRebuildRequest()) + await _register_workspace_files() info = get_workspace_info() + if index_service.get_status().vector_refresh_required: + index_service.schedule_workspace_rebuild() return WorkspaceSnapshot(workspace=info, items=get_workspace_tree()) +@serialized_vault_mutation +async def _register_workspace_files() -> None: + root = get_settings().vault_path.resolve() + paths = _disk_markdown_paths() + existing = {item.file_path: item for item in repository.list_note_locations()} + prepared = [] + for relative in sorted(paths - existing.keys()): + path = resolve_in_vault(relative) + stat = path.stat() + prepared.append(parse_note( + markdown=path.read_text(encoding='utf-8'), file_path=relative, + folder='' if path.parent == root else path.parent.relative_to(root).as_posix(), + tags=None, created_at=datetime.fromtimestamp(stat.st_ctime, timezone.utc), + updated_at=datetime.fromtimestamp(stat.st_mtime, timezone.utc), + )) + conn = connect() + try: + with transaction(conn): + for relative in existing.keys() - paths: + block_ids = repository.delete_note(existing[relative].note_id, conn=conn) + await vector_store.delete(block_ids, conn=conn) + for parsed in prepared: + repository.replace_note_metadata(conn=conn, note_id=parsed.note_id, title=parsed.title, + file_path=parsed.file_path, folder=parsed.folder, tags=parsed.tags, + created_at=parsed.created_at, updated_at=parsed.updated_at, blocks=parsed.blocks) + conn.execute('UPDATE blocks SET embedding_local_only=? WHERE note_id=?', (int(parsed.embedding_local_only), parsed.note_id)) + if prepared: + repository.set_index_meta({'workspace_vectors_pending': '1'}, conn=conn) + finally: + conn.close() + + @serialized_vault_mutation async def create_folder(parent: str, name: str) -> WorkspaceEntry: clean_parent = normalize_folder(parent) diff --git a/backend/tests/test_workspace_background.py b/backend/tests/test_workspace_background.py new file mode 100644 index 0000000..856bae1 --- /dev/null +++ b/backend/tests/test_workspace_background.py @@ -0,0 +1,131 @@ +import asyncio + +from app import repository +from app.config import get_settings +from app.services import index_service, workspace_service + + +def test_open_returns_before_vectors_and_deduplicates_background(monkeypatch): + async def scenario(): + started, release = asyncio.Event(), asyncio.Event() + original = index_service.prepare_note_index + calls = 0 + async def slow(*args, **kwargs): + nonlocal calls + calls += 1 + started.set() + await release.wait() + return await original(*args, **kwargs) + monkeypatch.setattr(index_service, 'prepare_note_index', slow) + vault = get_settings().vault_path + vault.mkdir(parents=True, exist_ok=True) + (vault / 'demo.md').write_text('# Demo\n\nsearchable content', encoding='utf-8') + try: + snapshot = await asyncio.wait_for(workspace_service.open_workspace(None), 1) + assert snapshot.items[0].note_id + await asyncio.wait_for(started.wait(), 1) + task = index_service._background_task + await asyncio.wait_for(workspace_service.open_workspace(None), 1) + assert index_service._background_task is task + assert index_service.get_status().status == 'running' + # A mutation still completes while the model is waiting. + await asyncio.wait_for(workspace_service.create_folder('/', 'new-folder'), 1) + assert repository.list_note_locations()[0].note_id == snapshot.items[0].note_id + release.set() + await asyncio.wait_for(task, 2) + assert calls == 1 + assert not index_service.get_status().vector_refresh_required + finally: + release.set() + await index_service.shutdown() + asyncio.run(scenario()) + + +def test_background_retries_changed_snapshot_without_overwriting(monkeypatch): + async def scenario(): + started, release = asyncio.Event(), asyncio.Event() + original = index_service.prepare_note_index + calls = 0 + async def slow(*args, **kwargs): + nonlocal calls + calls += 1 + if calls == 1: + started.set() + await release.wait() + return await original(*args, **kwargs) + monkeypatch.setattr(index_service, 'prepare_note_index', slow) + vault = get_settings().vault_path + vault.mkdir(parents=True, exist_ok=True) + path = vault / 'demo.md' + path.write_text('# Before\n\nold', encoding='utf-8') + try: + await workspace_service.open_workspace(None) + await asyncio.wait_for(started.wait(), 1) + path.write_text('# After\n\nnew', encoding='utf-8') + release.set() + await asyncio.wait_for(index_service._background_task, 4) + assert calls == 2 + assert repository.list_note_locations()[0].title == 'After' + assert not index_service.get_status().vector_refresh_required + finally: + release.set() + await index_service.shutdown() + asyncio.run(scenario()) + + +def test_save_returns_while_vectors_wait_and_latest_revision_wins(monkeypatch): + from app.services import note_service + async def scenario(): + note = await note_service.create_note(title='Draft', markdown='# Draft\n\ninitial', folder=None, tags=[]) + started, release = asyncio.Event(), asyncio.Event() + original = index_service.prepare_note_index + calls = 0 + async def slow(*args, **kwargs): + nonlocal calls + calls += 1 + if calls == 1: + started.set() + await release.wait() + return await original(*args, **kwargs) + monkeypatch.setattr(index_service, 'prepare_note_index', slow) + try: + await asyncio.wait_for(note_service.update_note(note.note_id, markdown='# First\n\none', defer_vectors=True), 1) + await asyncio.wait_for(started.wait(), 1) + await asyncio.wait_for(note_service.update_note(note.note_id, title='Custom title', tags=['kept'], markdown='# Latest\n\ntwo', defer_vectors=True), 1) + assert (await note_service.get_note(note.note_id)).markdown == '# Latest\n\ntwo' + assert index_service.get_status().vector_refresh_required + release.set() + await asyncio.wait_for(index_service._background_task, 3) + current = repository.get_note_record(note.note_id) + assert current.title == 'Custom title' + assert current.tags == ['kept'] + assert calls == 2 + assert not index_service.get_status().vector_refresh_required + finally: + release.set() + await index_service.shutdown() + asyncio.run(scenario()) + + +def test_failed_vectors_do_not_undo_save_and_pending_work_can_resume(monkeypatch): + from app.services import note_service + async def scenario(): + note = await note_service.create_note(title='Draft', markdown='# Draft', folder=None, tags=[]) + original = index_service.prepare_note_index + async def fail(*args, **kwargs): + raise RuntimeError('model unavailable') + monkeypatch.setattr(index_service, 'prepare_note_index', fail) + try: + await note_service.update_note(note.note_id, markdown='# Saved', defer_vectors=True) + await index_service._background_task + assert (await note_service.get_note(note.note_id)).markdown == '# Saved' + assert index_service.get_status().status == 'failed' + assert index_service.get_status().vector_refresh_required + await index_service.shutdown() + monkeypatch.setattr(index_service, 'prepare_note_index', original) + await workspace_service.open_workspace(None) + await index_service._background_task + assert not index_service.get_status().vector_refresh_required + finally: + await index_service.shutdown() + asyncio.run(scenario()) diff --git a/frontend/src/components/common/AppShell.vue b/frontend/src/components/common/AppShell.vue index 54373d5..26cc83f 100644 --- a/frontend/src/components/common/AppShell.vue +++ b/frontend/src/components/common/AppShell.vue @@ -1,5 +1,5 @@