How lawrence-anthony/buildwithgemini-data-pipeline-troubleshooting-assistant works
DataOps Agent is a conversational incident-diagnosis assistant for data-platform engineers. The primary workflow is browser chat through a same-origin FastAPI proxy and A2A to the agent, which inspects pipeline status and run history, compares failed and successful schemas, grounds guidance in runbooks, and can produce a visual incident diagram and interactive response. The README also documents cross-session memory and isolated Python analysis. External integrations and capability branches are shown; some tool wiring is documented but not visible in the sampled agent excerpt.
Main entry points: agent.py DataOps agent · fast_api_app.py FastAPI app · main.py Chat proxy · reasoning_engine_adapter.py Reasoning adapter
Components 16
Web interface
- Chat proxy
frontend/main.py - A2UI rendering
app/a2ui_utils.py
Agent serving
- Agent Platform
- A2A routes
app/app_utils/a2a.py - FastAPI app
app/fast_api_app.py - Shared services
app/app_utils/services.py - Reasoning adapter
app/app_utils/reasoning_engine_adapter.py
Incident diagnosis
- DataOps agent
app/agent.py
Cloud capabilities
- Pipeline store
- Runbook retrieval
- Python sandbox
- Image generation
- Cloud Storage
- Memory Bank
- Artifact service
Other components
- Engineer
Connections 18
- Engineer → Chat proxy: sends chat
- Chat proxy → Agent Platform: forwards A2A
- Agent Platform → A2A routes: dispatches RPC
- A2A routes → DataOps agent: runs agent
- DataOps agent → Pipeline store: queries pipeline data
- DataOps agent → Runbook retrieval: retrieves procedures
- DataOps agent → Python sandbox: executes analysis
- DataOps agent → Image generation: requests diagram
- DataOps agent → Cloud Storage: uploads diagram
- DataOps agent → Artifact service: saves image
- DataOps agent → Memory Bank: stores session findings
- DataOps agent → A2UI rendering: emits UI data
- Chat proxy → A2UI rendering: renders cards
- FastAPI app → A2A routes: attaches routes
- FastAPI app → Reasoning adapter: attaches routes
- Reasoning adapter → DataOps agent: dispatches methods
- Reasoning adapter → Shared services: gets shared services
- FastAPI app → Shared services: gets shared services