Function _gen_create

openkb/agent/compiler.py:1811–1836

(concept: dict)

    semaphore = asyncio.Semaphore(max_concurrency)

    async def _gen_create(concept: dict) -> tuple[str, str, bool, str]:
        name = concept["name"]
        title = concept.get("title", name)
        async with semaphore:
            raw = await _llm_call_page_async(
                model,
                [
                    system_msg,
                    doc_msg,  # cached (BP1)
                    summary_msg,  # cached (BP2)
                    known_targets_msg,  # cached (BP3) — whitelist
                    {
                        "role": "user",
                        "content": _CONCEPT_PAGE_USER.format(
                            title=title,
                            doc_name=doc_name,
                            update_instruction="",
                        ),
                    },
                ],
                f"concept: {name}",
                response_format=_JSON_RESPONSE_FORMAT,
            )
        brief, content, _ = _page_fields(raw)
        _require_nonempty_content(content, name)
        return name, content, False, brief

    async def _gen_update(concept: dict) -> tuple[str, str, bool, str]:
        name = concept["name"]