giers10/Heimgeist
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Refactor list_libraries to async and ensure background preparation jobs are running before listing libraries

Browse Source
This commit is contained in:
Victor Giers
2026-06-15 01:18:05 +02:00
parent a5142e6dd0
commit cbe30c6ccb
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
backend/local_rag.py
View File

@@ -1099,7 +1099,7 @@ def _build_local_context(prompt: str, results: Dict[str, Any], top_k: int = 5) -
@router.get("/libraries") @router.get("/libraries")
def list_libraries(): async def list_libraries():
libraries: List[Dict[str, Any]] = [] libraries: List[Dict[str, Any]] = []
for path in LIB_ROOT.iterdir(): for path in LIB_ROOT.iterdir():
if not path.is_dir(): if not path.is_dir():
@@ -1108,7 +1108,10 @@ def list_libraries():
if not meta.exists(): if not meta.exists():
continue continue
try: try:
libraries.append(library_payload(_read_json(meta))) data = _read_json(meta)
if _pipeline_meta(data).get("pending_prepare_signature") and not _has_active_job(data["slug"]):
await _ensure_prepare_job(data["slug"])
libraries.append(library_payload(read_library(data["slug"])))
except Exception: except Exception:
continue continue
libraries.sort(key=lambda item: item.get("created_at", ""), reverse=True) libraries.sort(key=lambda item: item.get("created_at", ""), reverse=True)