diff --git a/scripts/verify-governance.ts b/scripts/verify-governance.ts index f455ea3755..3afb7c9642 100644 --- a/scripts/verify-governance.ts +++ b/scripts/verify-governance.ts @@ -1,6 +1,4 @@ // SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. -// SPDX-License-Identifier: Apache-2.0 - // SPDX-License-Identifier: Apache-2.0 import { mkdirSync, writeFileSync } from "node:fs"; import { spawnSync } from "node:child_process"; diff --git a/scripts/verify-status-truth.ts b/scripts/verify-status-truth.ts index 68bc263bde..68041e85d0 100644 --- a/scripts/verify-status-truth.ts +++ b/scripts/verify-status-truth.ts @@ -23,8 +23,10 @@ const docs = { target: readFileSync("docs/architecture/target-state.md", "utf8"), }; -const rawFiles = execSync('find src test docs .github/workflows scripts -type f').toString('utf8').trim(); -const files = rawFiles ? rawFiles.split('\n') : []; +const rawFiles = execSync("rg --files src test docs .github/workflows scripts") + .toString("utf8") + .trim(); +const files = rawFiles ? rawFiles.split("\n") : []; const hasFile = (pattern: RegExp) => files.some((f) => pattern.test(f)); const components: Component[] = [ diff --git a/scripts/verify-threat-seams.ts b/scripts/verify-threat-seams.ts index 6282fd294d..a707e08592 100644 --- a/scripts/verify-threat-seams.ts +++ b/scripts/verify-threat-seams.ts @@ -1,6 +1,4 @@ // SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. -// SPDX-License-Identifier: Apache-2.0 - // SPDX-License-Identifier: Apache-2.0 import { spawnSync } from "node:child_process"; diff --git a/scripts/verify-version-drift.ts b/scripts/verify-version-drift.ts index 5009e58df1..7952806351 100644 --- a/scripts/verify-version-drift.ts +++ b/scripts/verify-version-drift.ts @@ -1,6 +1,4 @@ // SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. -// SPDX-License-Identifier: Apache-2.0 - // SPDX-License-Identifier: Apache-2.0 import { readFileSync } from "node:fs"; diff --git a/src/lib/control-plane/meshrag.ts b/src/lib/control-plane/meshrag.ts index 7e39000d39..3a3ea917c4 100644 --- a/src/lib/control-plane/meshrag.ts +++ b/src/lib/control-plane/meshrag.ts @@ -121,11 +121,12 @@ export async function ingestRecords(input: { records: RetrievalIngestionRecord[] if (input.embedding.status() === "unavailable") return { accepted: [], degraded: ["embedding_adapter_unavailable"] }; if (input.vectorStore.status() === "unavailable") return { accepted: [], degraded: ["vector_store_unavailable"] }; if (input.vectorStore.status() === "degraded") degraded.push("vector_store_degraded"); - const rows = []; - for (const record of input.records) { - const embedded = await input.embedding.embed({ text: record.content }); - rows.push({ recordId: record.recordId, vector: embedded.vector, record }); - } + const rows = await Promise.all( + input.records.map(async (record) => { + const embedded = await input.embedding.embed({ text: record.content }); + return { recordId: record.recordId, vector: embedded.vector, record }; + }) + ); await input.vectorStore.upsert(rows); return { accepted: rows.map((r) => r.recordId), degraded }; }