Self-Healing Orchestration - Advanced Live Demo

📐 System Architecture

[Ingest Log / Webhook] │ ▼ [IncidentDiagnosisAgent] ──(Deterministic Classification) │ ▼ [Primary Execution Attempt] ──(Builds Jira Payload v1.0) │ ├─► (Success: 201 Created) ──► Log Telemetry ──► Exit │ └─► [ANOMALY DETECTED] ──(Catches HTTP 400/422 Errors) │ ▼ [RCA & AutonomousSelfHealingEngine] ──(Claude Opus 5) │ ▼ [RE-EXECUTION NODE] ──(Dispatches Patched Payload v2.0) │ ▼ [TelemetryLog] ──(Persists Complete Audit Trail)

🎬 Execution Stages

1. INGEST

Receive incident webhook

2. DIAGNOSE

Deterministic P1-P4 classification

3. PRIMARY EXECUTION

Attempt Jira API call

4. ANOMALY DETECTION

Catch HTTP 400/422 errors

5. RCA + HEALING

Claude analyzes & patches payload

6. RE-EXECUTION

Send healed payload to API

7. TELEMETRY

Immutable audit trail logged

📊 Execution Log

Waiting for incident...

📈 Performance Metrics

0

Total Incidents

0

Heal Attempts

0%

Success Rate

$0.00

Total Cost

🔐 Immutable Audit Trail

No incidents processed yet

✓ Architectural Strengths

• Deterministic Triage Layer: The IncidentDiagnosisAgent uses strict keyword mapping ("connection refused", "timeout", "out of memory") to assign P1-P4 severities without calling an LLM. This eliminates hallucination risks during initial diagnostic phase.

• Isolated Claude Remediation Loop: The AutonomousSelfHealingEngine is invoked only when an exception occurs (ANOMALY_DETECTED). It isolates the raw error JSON and bad payload, forcing Claude to return strict, unformatted raw JSON.

• State Auditability: The TelemetryLog class creates an immutable, timestamped audit trail of every stage. This satisfies enterprise governance and compliance requirements for automated execution.

• Production Interface: Wrapping the engine inside FastAPI (/incidents/ingest) makes the script immediately deployable as a background microservice or webhook receiver.

⚙️ Optimization: Explicit Error Parsing

def _parse_error(self, err: Exception) -> Dict:
    if isinstance(err, aiohttp.ClientResponseError):
        return {
            "error_code": "SCHEMA_MISMATCH" if err.status == 422 
                         else "INVALID_PAYLOAD",
            "status": err.status,
            "error_message": err.message,
            "details": str(err)
        }
    return {
        "error_code": "UNKNOWN_ERROR",
        "status": 500,
        "error_message": "Unexpected API error",
        "details": str(err)
    }

For maximum reliability when connecting to live enterprise endpoints, parse the direct HTTP status code from aiohttp.ClientResponseError or the structured JSON error body directly.