How akash-8991/renewable_energy_orchestrator works
Renewable Energy Orchestrator is a multi-tenant renewable-energy decision and control platform. Users configure assets and connectors, ingest telemetry and documents, inspect forecasts and proposed decisions, and manage approvals and operations through a web console. Its backend and policy workers support the decision lifecycle; specialist agents add evidence-based review after decisions are ready. The tree also exposes simulation, governance, audit, and export capabilities. The supplied excerpts show only parts of this system, so unsampled subsystem links are omitted or marked unverified rather than inferred as confirmed calls.
Main entry points: events.py Telemetry stream · main.py Backend API · cycle.py Decision cycle · model_gateway.py Model gateway
Components 23
User experience
- Web console
platform/frontend/src/App.tsx
Platform API and intake
- Backend API
platform/backend/app/main.py - Ingestion routes
platform/backend/app/routers/ingestion.py - Ingestion services
platform/backend/app/ingestion - Telemetry stream
platform/packages/reo_common/reo_common/events.py - Edge simulator
platform/infrastructure/edge-simulator/simulator.py
Decision lifecycle
- Decision cycle worker
platform/policy/worker.py - Decision cycle
platform/policy/cycle.py - Forecasting
platform/policy/forecast.py - Optimizer
platform/policy/solver.py - Scenario simulation
platform/policy/scenario_lab.py - Agent orchestration
platform/agent/worker.py - Evidence assembly
platform/agent/context.py - Specialist agents
platform/agent/agents
Shared platform services
- Canonical domain model
platform/models/canonical.py - Tenant-isolated database
platform/database/connection.py - Model gateway
platform/packages/reo_common/reo_common/model_gateway.py - Platform settings
platform/packages/reo_common/reo_common/config.py
Controls and outputs
- Model guardrails
platform/guardrails/circuit_breaker.py - Governance and policy
platform/backend/app/routers/governance.py - Audit records
platform/output/audit.py - Export worker
platform/output/export-worker/worker.py
Other components
- Platform user
Connections 27
- Platform user → Web console: uses
- Web console → Backend API: calls API
- Backend API → Ingestion routes: registers routes
platform/backend/app/main.py - Ingestion routes → Ingestion services: uses intake
platform/backend/app/routers/ingestion.py - Ingestion routes → Model gateway: requests mappings
platform/backend/app/routers/ingestion.py - Ingestion services → Telemetry stream: publishes events
platform/backend/app/ingestion/file_ingest.py - Edge simulator → Tenant-isolated database: writes telemetry
platform/infrastructure/edge-simulator/simulator.py - Edge simulator → Telemetry stream: publishes events
platform/infrastructure/edge-simulator/simulator.py - Decision cycle worker → Decision cycle: runs cycle
platform/policy/worker.py - Decision cycle worker → Telemetry stream: consumes events
platform/policy/worker.py - Decision cycle → Forecasting: requests forecast
platform/policy/cycle.py - Decision cycle → Optimizer: requests optimization
platform/policy/cycle.py - Decision cycle → Tenant-isolated database: reads and writes decisions
platform/policy/cycle.py - Scenario simulation → Optimizer: uses optimizer
- Agent orchestration → Telemetry stream: consumes decision events
platform/agent/worker.py - Agent orchestration → Evidence assembly: assembles evidence
platform/agent/worker.py - Agent orchestration → Specialist agents: dispatches agents
platform/agent/worker.py - Evidence assembly → Canonical domain model: reads domain records
platform/agent/context.py - Specialist agents → Model gateway: requests structured output
platform/agent/agents/optimisation_reviewer.py - Model gateway → Platform settings: loads provider settings
platform/packages/reo_common/reo_common/model_gateway.py - Model gateway → Model guardrails: uses circuit breaker
platform/packages/reo_common/reo_common/model_gateway.py - Governance and policy → Canonical domain model: manages policies
- Export worker → Tenant-isolated database: reads export data
platform/output/export-worker/worker.py - Export worker → Telemetry stream: uses event bus
platform/output/export-worker/worker.py - Audit records → Canonical domain model: records domain events
platform/output/audit.py - Backend API → Governance and policy: registers routes
platform/backend/app/main.py - Backend API → Tenant-isolated database: configures sessions