🧹 Kehrwoche AI
← Back to Main

n8n Workflow Design

Interactive visualization of the Kehrwoche AI Agent and Copilot RAG pipelines — modelled as n8n-style node workflows.

1 Trigger
⏰
EventBridge
Cron: hourly during Q1/Q3
aws:eventbridgecron: 0 * * * *
invokes
2 Orchestrator
🧬
Orchestrator Agent
Central coordinator — plans, delegates, retries
state: DynamoDBretry: 3×timeout: 30min
🧠 Agent State — run_id status fact_sheets[] drafts[] errors[]
📋 PLANNING SUB-AGENT
3
📡
Fetch Open To-Dos
GraphQL allFactSheets query
tool: leanix_graphql
4
🔀
Dedup + Filter
Skip already-processed in DynamoDB
tool: dynamodb_query
5
📝
Build Execution Plan
Group by PO, load skill_guide.yaml
tool: skill_guide_loaderoutput: plan.json
🔄 FOR EACH fact sheet in execution plan
🔍 SOURCE RESOLUTION SUB-AGENT
6
🔍
Resolve Sources (Priority Chain)
4-level fallback: org props → externalId → file scan → fuzzy match
tool: github_org_props tool: leanix_external_id tool: repo_file_scanner tool: fuzzy_matcher
95%+ hit rate
💾 Cache mappings — returns: github_repo confluence_space jira_project iam_app alice_users cloud_accounts
📂 EVIDENCE GATHERING SUB-AGENT
⚡ PARALLEL TOOL CALLS — fetch evidence concurrently
💻
GitHub
Tech stack, Dockerfile, CI
tool: github_api
📋
Jira
Roles, releases, sprints
tool: jira_api
📖
Confluence
Arch docs, data protection
tool: confluence_api
🛡️
Archer
Security class, availability
tool: archer_api
📊
LeanIX
Relations, org structure
tool: leanix_graphql
🔑
IAM
App registration, auth
tool: iam_api
👥
Alice
User details, org contacts
tool: alice_api
☁️
Cloud Accounts
AWS/Azure hosting, region
tool: cloud_accounts_api
MERGE — Assemble evidence bundle per question
🧠 REASONING SUB-AGENT
7
📋
Skill Guide Lookup
Map question → answering strategy
config: skill_guide.yaml
?
Strategy: Deterministic or LLM?
~70% Rules
8a
⚙️
Rules Engine
Direct lookup from evidence
tool: rule_engineconfidence: 1.0
~30% LLM
8b
🧠
LLM Answerer
Nexus — structured JSON output
tool: nexus_llmformat: json_mode
MERGE — Combine all answers per fact sheet
9
✅
Quality Gate
All answers present, confidence ≥ 0.8, enums valid
tool: answer_validatorretry: low-confidence
💾 Persist answers — drafts/{po_email}/{fs_id}
🔁 END FOR EACH — all fact sheets processed
📧 NOTIFICATION SUB-AGENT
10
📦
Bundle per PO
Aggregate drafts by RESPONSIBLE
tool: po_bundler
11
🔐
HMAC Tokens
SHA-256 signed approval URLs
tool: hmac_signerttl: 30d
12
📧
Send Email
HTML with answers + "Approve All"
tool: smtp_senderrelay: corporate
👤 HUMAN-IN-THE-LOOP
🛑
PO Review Gate
Agent pauses — PO reviews answers in email, optionally edits via Copilot
13
⏳
Escalation Timer
7d remind · 14d escalate · 30d expire
tool: reminder_scheduler
PO clicks Approve
14
🔗
Lambda Validate
Verify HMAC + expiry + binding
tool: hmac_validatoraws: lambda_url
15
✏️
Write to LeanIX
GraphQL mutations + audit trail
tool: leanix_mutatetool: audit_logger
16 Done
✅
Confirmation
Summary email + Copilot link
tool: smtp_sender
🏁 Run Complete — status: done approved: N pending: M expired: K
Trigger
Tool Call / API
Condition / Gate
Data / Transform
LLM / AI
Notification
Orchestrator
Human-in-the-Loop
1 User
👤
Product Owner
Opens Copilot from email or portal
2
💬
User Question
Natural language query
"How do I fill Cloud Nativity?"
3
📐
Embed Query
multilingual-e5 → 384-dim
tool: embedding_model
4
🔍
Vector Search
FAISS index — Top-5 chunks
tool: faiss_search
🧠 LLM GENERATION — Nexus Model Garden
5
🧠
LLM Generation
Context + App Data + KB Sources → Answer with citations
tool: nexus_llmformat: json_mode
Knowledge Sources
🤖
Agent Resultspre-filled answers
📊
LeanIXfact sheet data
📄
User GuidePDF chunks
📋
KehrwocheExcel
📜
PoliciesRISE / GDPR
⚙️
Field Metaenums / rules
💻
GitHubrepo context
🔑
IAMApp Details
👥
AliceUser Details
☁️
Cloud AcctsAWS / Azure
6
✅
Response
Answer + citations + "Apply" button
7
🔀
PO Decision
Accept, edit, or ask more?
?
Apply changes to LeanIX?
✅ Apply
8a
✏️
LeanIX Write
GraphQL mutation → update field
tool: leanix_mutate
📝
Audit Log
DynamoDB — change + evidence
tool: audit_logger
💬 Edit / Ask
8b
🔄
Continue Chat
Follow-up question → loops back
Loops back to step 2
Trigger
Tool Call / API
Condition / Gate
Data / Transform
LLM / AI
Notification
Human / User