⬡ Pipeline Architecture
Kafka / Cron / Webhook
│
[n8n Trigger]
│
[Triage Agent] ◄── Claude API
│ (reports signals only)
┌────┴──────────┐
│ │ │
[SQL Valid.] [Log Analyser] [Schema Cmp.]
│ │ │
└───────┬────────────────────────┘
│
[Severity Classifier]
deterministic — config/severity.yml
│
┌─────┴──────┐
clean incident (P1–P4)
│ │
[Robot FW] [pytest]
│ │
└────┬───────┘
│
[Slack Bot] + [Jenkins]
threaded · Approve/Reject/Escalate
n8n
Claude API
FastAPI
Slack Block Kit
Robot Framework
pytest
Kafka
PostgreSQL
⚡ Pipeline Trigger
📋 Execution Steps
1
Pipeline Event Received
Waiting for trigger…
2
Claude Calls Triage Tools
sql_validator · log_analyser · schema_comparator
3
Severity Classified
Deterministic — same signals, same call, every time
4
Validation Framework Invoked
Clean → Robot Framework · Incident → pytest
5
Posted to Slack
Incident record opened, threaded, awaiting response
🧠 Agent Reasoning Log
Select a failure mode and click Run Pipeline to watch
signals get classified into a severity — and, on an incident, try the Approve/Reject/Escalate buttons below.
signals get classified into a severity — and, on an incident, try the Approve/Reject/Escalate buttons below.
🗄️ SQL Validator
IDLE
Source rows: —
Target rows: —
Row variance: —
Null rate (cust_id): —
📋 Log Analyser
IDLE
Errors: —
Warnings: —
Kafka lag: —
🔍 Schema Comparator
IDLE
Added cols: —
Removed cols: —
Renamed cols: —
Type changes: —
💬 #etl-prod-alerts — Slack Message Preview
This is a static rendering of the exact Block Kit structure
agent/slack_blocks.py builds and agent/slack_client.py posts — try the buttons below.🧪 Test Results