⚡ Optimize sequential embedding generation to run in parallel

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";

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[] = [

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";
 

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";
 

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 };
 }