# a. Orchestrator Engine

**Responsibility**: Central coordination and decision-making

**Core Functions**:

```
class OrchestratorEngine:
    async def coordinate_agents(self) -> None
    async def prioritize_actions(self, actions: List[Action]) -> List[Action]
    async def execute_emergency_protocol(self) -> None
    async def health_check_all_agents(self) -> Dict[str, AgentStatus]
```

| Risk Level | Liquidation Health | Redemption Risk | Action Priority |
| ---------- | ------------------ | --------------- | --------------- |
| Safe       | > 2.0              | Low             | Monitor         |
| Warning    | 1.5 - 2.0          | Medium          | Adjust Rates    |
| Danger     | 1.2 - 1.5          | High            | Add Collateral  |
| Critical   | < 1.2              | Critical        | Emergency Close |