How akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform works
NexusAgent accepts enterprise questions through a web workbench or API, manages session context and security, routes work to knowledge, data, or joint-risk skills, and reviews evidence before returning a grounded answer or clarification. Its knowledge branch combines clause-aware retrieval with citations; its data branch plans and guards read-only SQL over an enterprise database. The graph follows README-documented orchestration and capabilities, supplemented by sampled API, retrieval, planning, context, and query-service code; unsampled subsystem wiring is shown only where documented.
Main entry points: executor.py Request Executor · pipeline.py Hybrid Retrieval · coordinator.py Skill Coordinator · request_router.py Request Router
Components 31
Serving and Runtime
- Web Workbench
src/decision_agent/web/app.js - FastAPI Gateway
src/decision_agent/api/app.py - Agent API Route
src/decision_agent/api/routes.py - Request Executor
src/decision_agent/application/executor.py
Context and Orchestration
- Context Manager
src/decision_agent/context/manager.py - Session Store
src/decision_agent/memory/store.py - Security Policies
src/decision_agent/security/policy.py - Request Router
src/decision_agent/routing/request_router.py - Skill Coordinator
src/decision_agent/coordination/coordinator.py
Knowledge Retrieval
- Knowledge QA Skill
src/decision_agent/skills/enterprise_knowledge_qa.py - Hybrid Retrieval
src/decision_agent/retrieval/pipeline.py - Milvus Vector Store
src/decision_agent/retrieval/milvus_store.py - BM25 Search
src/decision_agent/retrieval/bm25.py - Rank Fusion
src/decision_agent/retrieval/fusion.py - Cross-Encoder Reranker
src/decision_agent/retrieval/reranking.py - Parent Expansion
src/decision_agent/retrieval/parent_expansion.py - Clause-Aware Ingestion
src/decision_agent/ingestion/clause_aware_chunking.py
Guarded Data Access
- Data Analysis Skill
src/decision_agent/skills/enterprise_data_analysis.py - Data Query Planner
src/decision_agent/agents/data_query_planner.py - MCP Data Client
src/decision_agent/mcp_client/enterprise_data_client.py - MCP Data Server
src/decision_agent/mcp_server/enterprise_data_server.py - Safe Query Service
src/decision_agent/data/safe_query_service.py - SQL AST Guard
src/decision_agent/data/sql_guard.py - Enterprise SQL Database
Evidence and Decisions
- Inventory Risk Diagnosis
src/decision_agent/skills/inventory_risk_diagnosis.py - Risk Policy Synthesizer
src/decision_agent/skills/inventory_risk_synthesizer.py - Answerability Reviewer
src/decision_agent/agents/answerability_reviewer.py - Grounded Answer
src/decision_agent/agents/grounded_answer.py
Other components
- Enterprise User
- LLM Provider
- Verified Result or Clarification
Connections 32
- Enterprise User → Web Workbench: submits question
- Web Workbench → FastAPI Gateway: sends request
- Enterprise User → FastAPI Gateway: calls API
- FastAPI Gateway → Agent API Route: dispatches request
- Agent API Route → Request Executor: executes request
- Request Executor → Context Manager: selects context
- Context Manager → Session Store: loads and saves
- Request Executor → Security Policies: checks scope
- Request Executor → Request Router: routes question
- Request Router → LLM Provider: requests route
- Request Router → Skill Coordinator: returns route
- Skill Coordinator → Knowledge QA Skill: dispatches knowledge
- Skill Coordinator → Data Analysis Skill: dispatches data
- Skill Coordinator → Inventory Risk Diagnosis: dispatches mixed work
- Knowledge QA Skill → Hybrid Retrieval: retrieves evidence
- Hybrid Retrieval → Milvus Vector Store: dense search
- Hybrid Retrieval → BM25 Search: lexical search
- Hybrid Retrieval → Rank Fusion: fuses rankings
- Hybrid Retrieval → Cross-Encoder Reranker: reranks candidates
- Hybrid Retrieval → Parent Expansion: expands context
- Clause-Aware Ingestion → Milvus Vector Store: indexes chunks
- Data Analysis Skill → Data Query Planner: plans query
- Data Query Planner → LLM Provider: requests plan
- Data Analysis Skill → MCP Data Client: requests data
- MCP Data Client → MCP Data Server: calls MCP tools
- MCP Data Server → Safe Query Service: executes query
- Safe Query Service → SQL AST Guard: authorizes SQL
- Safe Query Service → Enterprise SQL Database: runs read-only SQL
- Inventory Risk Diagnosis → Risk Policy Synthesizer: synthesizes risks
- Request Executor → Answerability Reviewer: reviews evidence
- Answerability Reviewer → Grounded Answer: grounds response
- Request Executor → Verified Result or Clarification: returns outcome