Metadata-Version: 2.4
Name: sota-agent-framework
Version: 0.4.2
Summary: Domain-agnostic agent framework for integrating AI agents into data pipelines
Author: Agent Framework Team
License: MIT
Project-URL: Homepage, https://github.com/your-org/sota-agent-framework
Project-URL: Documentation, https://github.com/your-org/sota-agent-framework/tree/main/docs
Project-URL: Repository, https://github.com/your-org/sota-agent-framework
Project-URL: Issues, https://github.com/your-org/sota-agent-framework/issues
Keywords: agents,agentic-ai,databricks,mlops,llm,framework,agent-orchestration,plug-and-play
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: Topic :: Software Development :: Libraries :: Application Frameworks
Classifier: Topic :: Scientific/Engineering :: Artificial Intelligence
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Requires-Python: >=3.9
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: pydantic<3.0.0,>=2.0.0
Requires-Dist: pydantic-settings>=2.0.0
Requires-Dist: pyyaml>=6.0
Requires-Dist: httpx>=0.25.0
Requires-Dist: packaging>=23.0
Provides-Extra: databricks
Requires-Dist: databricks-sdk>=0.20.0; extra == "databricks"
Requires-Dist: databricks-sql-connector>=3.0.0; extra == "databricks"
Requires-Dist: mlflow>=2.10.0; extra == "databricks"
Provides-Extra: agent-frameworks
Requires-Dist: langgraph>=0.2.0; extra == "agent-frameworks"
Requires-Dist: langchain>=0.2.0; extra == "agent-frameworks"
Requires-Dist: langchain-core>=0.2.0; extra == "agent-frameworks"
Provides-Extra: optimization
Requires-Dist: dspy-ai>=2.4.0; extra == "optimization"
Requires-Dist: textgrad>=0.1.0; extra == "optimization"
Provides-Extra: ray
Requires-Dist: ray[default]>=2.0.0; extra == "ray"
Provides-Extra: mcp
Requires-Dist: mcp>=0.1.0; extra == "mcp"
Provides-Extra: a2a
Requires-Dist: a2a-sdk>=0.3.0; extra == "a2a"
Provides-Extra: semantic-search
Requires-Dist: sentence-transformers>=2.2.0; extra == "semantic-search"
Provides-Extra: messaging
Requires-Dist: nats-py>=2.6.0; extra == "messaging"
Requires-Dist: redis>=5.0.0; extra == "messaging"
Provides-Extra: telemetry
Requires-Dist: opentelemetry-api>=1.20.0; extra == "telemetry"
Requires-Dist: opentelemetry-sdk>=1.20.0; extra == "telemetry"
Requires-Dist: opentelemetry-instrumentation>=0.41b0; extra == "telemetry"
Provides-Extra: web
Requires-Dist: fastapi>=0.100.0; extra == "web"
Requires-Dist: uvicorn[standard]>=0.23.0; extra == "web"
Requires-Dist: websockets>=12.0; extra == "web"
Provides-Extra: monitoring
Requires-Dist: psutil>=5.9.0; extra == "monitoring"
Provides-Extra: ui
Requires-Dist: plotly>=5.0.0; extra == "ui"
Requires-Dist: gradio>=4.0.0; extra == "ui"
Requires-Dist: ipython>=8.0.0; extra == "ui"
Provides-Extra: documents
Requires-Dist: PyPDF2>=3.0.0; extra == "documents"
Requires-Dist: python-docx>=0.8.11; extra == "documents"
Provides-Extra: all
Requires-Dist: sota-agent-framework[a2a,agent-frameworks,databricks,documents,mcp,messaging,monitoring,optimization,ray,semantic-search,telemetry,ui,web]; extra == "all"
Provides-Extra: dev
Requires-Dist: pytest>=7.4.0; extra == "dev"
Requires-Dist: pytest-asyncio>=0.21.0; extra == "dev"
Requires-Dist: pytest-cov>=4.1.0; extra == "dev"
Requires-Dist: black>=23.0.0; extra == "dev"
Requires-Dist: ruff>=0.1.0; extra == "dev"
Requires-Dist: mypy>=1.5.0; extra == "dev"
Requires-Dist: ipython>=8.12.0; extra == "dev"
Requires-Dist: jupyter>=1.0.0; extra == "dev"
Dynamic: license-file

[![PyPI](https://img.shields.io/pypi/v/agent-framework)](https://pypi.org/project/agent-framework/)
[![License](https://img.shields.io/badge/License-MIT-blue.svg)](LICENSE)

# Agent Framework

**Production-ready template for building AI agent workflows in any domain.**

Build intelligent agents with memory, reasoning, optimization, and seamless Databricks integration. Start simple, scale to autonomous systems.

---

## 🚀 Quick Start

### Installation

```bash
# Basic (core features only)
pip install agent-framework

# With features you need
pip install agent-framework[all]  # Everything
pip install agent-framework[databricks]  # Databricks integration
pip install agent-framework[optimization]  # DSPy + TextGrad
```

### Choose Your Path

**🤖 Have a Use Case? (NEW! - AI-Powered)**
```bash
# From text
agent-architect "Build a fraud detection system with memory and self-improvement"

# From document (txt, md, pdf, docx)
agent-architect --file requirements.txt
# → Instant architecture recommendation: Level, schemas, features, integrations!
```
Describe your use case in natural language or provide a document, get instant recommendations.

**🎓 Want to Learn? (NEW!)**
```bash
agent-learn  # Interactive learning mode - build 5 progressively complex examples
```
Learn by building: chatbot → context-aware → production API → complex workflow → autonomous multi-agent

**🚀 New to Agents?**
```bash
agent-setup  # Interactive wizard guides you through
```

**🔧 Building an Agent?**
```bash
agent-generate --domain "fraud_detection" --output ./my-agent
cd my-agent && agent-advisor .  # Get recommendations
```

**⚡ Expert?**
```bash
# Use the framework as a library
from agents import Agent, AgentRouter
from memory import MemoryManager
from orchestration import AgentWorkflowGraph
```

**📖 [See complete getting started guide →](GETTING_STARTED.md)**  
**🎓 [See learning path →](docs/LEARNING_PATH.md)**

---

## ✨ Key Features

### Core Framework
- ⚡ **Multiple Execution Modes** - In-process, parallel, Ray, serverless
- 🔌 **Pluggable Architecture** - Use only what you need
- 📝 **Type-Safe Schemas** - Pydantic models throughout
- ⚙️ **YAML Configuration** - Infrastructure as code

### Agent Intelligence
- 🧠 **Agent-Governed Memory** - Smart storage, retrieval, reflection, forgetting
- 🎯 **Reasoning Optimization** - Trajectory tuning, CoT distillation, self-improvement
- 🔄 **Plan-Act-Critique Loops** - LangGraph-powered orchestration
- 🤝 **A2A Protocol (Official)** - Linux Foundation standard for cross-framework agent communication
- 📊 **Comprehensive Benchmarking** - 6+ metrics, regression testing

### Production Ready
- 🏢 **Databricks Native** - Unity Catalog, Delta Lake, MLflow integration
- 📈 **Complete Observability** - OpenTelemetry, execution graphs, trace replay
- 🔧 **Prompt Optimization** - DSPy & TextGrad for auto-tuning
- 🌐 **REST & WebSocket APIs** - Production services included
- 🎛️ **Experiment Tracking** - Feature flags, A/B testing, MLflow

### Developer Experience
- 🎯 **Progressive Disclosure** - Strong defaults for beginners, full control for experts
- 🤖 **AI-Powered Tools** - `agent-architect`, `agent-setup`, `agent-generate`, `agent-advisor`, `agent-benchmark`, `agent-learn`, `agent-deploy`
- 📚 **8 Core Docs** - Clear, concise, use-case driven
- 🔍 **Use-Case Guidance** - Know exactly which features you need
- 🚀 **Deployment Ready** - Docker, K8s, Databricks, Serverless templates included

---

## 🏗️ Technology Stack

Built on industry-leading technologies for production-grade AI agents:

| Component | Technology | Production Config |
|-----------|-----------|-------------------|
| **Agent Runtime** | Databricks Apps (hot pools) | `min_instances: 2`, `scale_to_zero: false` |
| **LLM Inference** | Databricks Model Serving | Always-on (no scale-to-zero) |
| **Orchestration** | LangGraph + Databricks Workflows | Plan → Act → Critique loops |
| **Agent Memory** | Lakebase + Delta Lake (UC) | Async vector + metadata queries |
| **A2A Transport** | FastAPI/Starlette (in container) | JSON-RPC 2.0, peer-to-peer |
| **MCP Servers** | FastAPI/Starlette (in container) | Tool/resource discovery |
| **Telemetry** | OTEL → ZeroBus → Delta Lake | Batch writes (10s/1000 events) |
| **Prompt Registry** | Unity Catalog Volumes | Version-controlled, auto-refresh |
| **Prompt Optimization** | DSPy + TextGrad (offline jobs) | Scheduled (nightly), no runtime overhead |
| **Tracing & Evaluation** | Databricks MLflow | Experiment tracking, model registry |
| **Dashboards** | Databricks SQL | Real-time agent metrics |

---

## 📦 Use Cases

**Works for any agent workflow:**
- 🔒 Fraud Detection & Risk Analysis
- 💬 Customer Support & Chatbots
- 📝 Content Moderation
- 🏥 Healthcare & Diagnostics
- 🔍 Data Quality & Anomaly Detection
- 📊 Analytics & Report Generation
- 🤖 **Your Use Case Here**

---

## 📖 Documentation

**Start Here:**
1. **[Getting Started](GETTING_STARTED.md)** - 5-minute setup
2. **[User Journey](docs/USER_JOURNEY.md)** - Choose your path (Beginner/Intermediate/Advanced)
3. **[Feature Selection](docs/FEATURE_SELECTION.md)** - Which features do YOU need?

**Core Guides:**
- **[Architecture Advisor](docs/ARCHITECTURE_ADVISOR.md)** - AI-powered recommendations
- **[Learning Path](docs/LEARNING_PATH.md)** - Learn by building (5 levels)
- **[Integrations](docs/INTEGRATIONS.md)** - MCP, LangGraph, Databricks, A2A
- **[Advanced Features](docs/ADVANCED_FEATURES.md)** - Memory, Reasoning, Optimization, Benchmarking

**Quick Links:**
- [Documentation Map](DOCUMENTATION_MAP.md) - Complete navigation guide
- [Examples](examples/) - Working code examples
- [Benchmarks](benchmarks/) - Evaluation suites

---

## 🛠️ CLI Tools

```bash
# 🎓 Interactive learning mode (NEW!)
agent-learn              # Learn by building 5 progressively complex examples
agent-learn start 1      # Start Level 1: Simple Chatbot
agent-learn start 2      # Start Level 2: Context-Aware Assistant

# Interactive setup wizard (use-case based)
agent-setup

# Generate new project
agent-generate --domain "your_domain" --output ./project

# Analyze project & get recommendations
agent-advisor ./project

# Run benchmarks & evaluations
agent-benchmark run --suite fraud_detection --report md

# Deploy to production (NEW!)
agent-deploy init --platform kubernetes  # Generate deployment configs
agent-deploy build --tag v1.0.0          # Build Docker image
agent-deploy status                       # Check deployment readiness
```

---

## 🎯 Feature Selection Guide

| Use Case | Memory | Reasoning | Optimization | Monitoring | LangGraph |
|----------|--------|-----------|--------------|------------|-----------|
| **Simple Chatbot** | ⚪ Optional | ❌ No | ❌ No | ⚪ Optional | ❌ No |
| **Context-Aware Agent** | ✅ Yes | ⚪ Optional | ⚪ Optional | ✅ Yes | ⚪ Optional |
| **Production API** | ⚪ Optional | ❌ No | ⚪ Optional | ✅ Yes | ❌ No |
| **Complex Workflows** | ✅ Yes | ✅ Yes | ⚪ Optional | ✅ Yes | ✅ Yes |
| **Autonomous Agent** | ✅ Yes | ✅ Yes | ✅ Yes | ✅ Yes | ✅ Yes |

**📖 [See detailed feature guide →](docs/FEATURE_SELECTION.md)**

---

## 🏗️ Architecture

```
Agent Framework
├── agents/           # Core agent classes & registry
├── memory/           # Agent-governed memory system
├── reasoning/        # Trajectory optimization & feedback
├── optimization/     # DSPy & TextGrad prompt optimization
├── orchestration/    # LangGraph workflows
├── evaluation/       # Benchmarking & metrics
├── visualization/    # Databricks-native observability
├── telemetry/        # OpenTelemetry → Delta Lake
├── uc_registry/      # Unity Catalog integration
├── experiments/      # Feature flags & A/B testing
├── monitoring/       # Health checks & metrics
├── services/         # REST API & WebSocket
└── infra/            # Terraform for Databricks
```

**📖 [See detailed architecture →](docs/USER_JOURNEY.md)**

---

## 🚀 Example: Fraud Detection Agent

```python
from agents import Agent, CriticalPathAgent
from memory import MemoryManager
from orchestration import AgentWorkflowGraph

# Define agent
class FraudDetectorAgent(CriticalPathAgent):
    async def process(self, input_data):
        # Check memory for similar cases
        similar = await self.memory.retrieve(
            query=f"transaction {input_data.transaction_id}",
            top_k=5
        )
        
        # Run detection
        result = await self.detect_fraud(input_data)
        
        # Store in memory
        await self.memory.store(result, importance="HIGH")
        
        return result

# Use with LangGraph for complex workflows
workflow = AgentWorkflowGraph(agent_router=router)
workflow.add_node("planner", PlannerNode())
workflow.add_node("detector", FraudDetectorAgent())
workflow.add_node("critic", CriticNode())

result = await workflow.run(transaction_data)
```

**📖 [See more examples →](examples/)**

---

## 🤝 Contributing

We welcome contributions! See our contribution guidelines (coming soon) or file an issue.

---

## 📄 License

MIT License - see [LICENSE](LICENSE) for details.

---

## 🔗 Links

- **PyPI**: https://pypi.org/project/agent-framework/
- **GitHub**: https://github.com/somasekar278/universal-agent-template
- **Documentation**: [DOCUMENTATION_MAP.md](DOCUMENTATION_MAP.md)

---

## ⭐ What Makes This Agent?

Unlike orchestration-only or research-only agent frameworks, SOTA Agent ships a complete agentic development stack including autonomous planning loops, agent-governed memory, reasoning trajectory optimization, prompt auto-tuning, benchmark harnesses, and governed deployment — built for real data pipelines and production SLAs

✅ **Agent-Governed Memory** - Not just storage, intelligent decisions  
✅ **Plan-Act-Critique Loops** - True autonomous workflows  
✅ **Reasoning Optimization** - Learn from execution trajectories  
✅ **Comprehensive Benchmarking** - Track performance over time  
✅ **Databricks Native** - Production-ready from day one  
✅ **Progressive Disclosure** - Works for beginners AND experts  
✅ **Modular Design** - Use only what you need  

**🚀 [Get started now →](GETTING_STARTED.md)**
