From 436a2be75fe5d3d87a16ef534d51a3eac1b6e59f Mon Sep 17 00:00:00 2001 From: Marker689 Date: Mon, 11 May 2026 20:55:36 +0300 Subject: [PATCH] refactor: parallel LLM analysis via asyncio.gather instead of sequential --- guarddog_nexus/core/harvester.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/guarddog_nexus/core/harvester.py b/guarddog_nexus/core/harvester.py index 1d291fb..3adb64b 100644 --- a/guarddog_nexus/core/harvester.py +++ b/guarddog_nexus/core/harvester.py @@ -228,12 +228,15 @@ async def _run_llm_analysis(findings: list[Finding], session: AsyncSession) -> l await session.commit() reports = [] - for finding in findings: + + async def _analyze_one(finding): report = await analyze_finding(finding.data) if report: finding.report = report reports.append(report) else: finding.report = None + + await asyncio.gather(*(_analyze_one(f) for f in findings)) await session.commit() return reports