Skip to content

v0.2.0 - Production ML Versioning & Orchestration

Latest
Latest

Choose a tag to compare

View all tags
@Mullassery Mullassery released this 27 Jul 17:12
· 54 commits to main since this release
v0.2.0
98f9c6d

PyStreamAI v0.2.0: Production-Grade ML Model Management

What's New

Phase 5: Advanced Rollback Strategies

  • Instant Rollback — < 1 second automatic recovery
  • Canary Rollback — Gradual 10% → 25% → 50% → 100% with health checks
  • Blue-Green Rollback — Instant switch with old version standby
  • Shadow Rollback — Validate before production switch

Phase 6: Cost & Performance Optimization

  • Cost Tracking — Per-inference cost calculation with projections
  • Performance Benchmarking — Latency percentiles, statistical significance
  • Auto-Recommendations — Identify optimal versions automatically

Phase 8: Framework Integration

  • TensorFlow Serving — Native SavedModel support
  • PyTorch/TorchServe — PyTorch model deployment
  • Kubernetes — Native K8s deployment with service routing
  • Hugging Face Hub — Download and version HF models
  • Framework Auto-Detection — Automatic framework detection

Phase 9: Advanced Analytics

  • Root Cause Analysis — Identify 7+ probable causes of degradation
  • Drift Detection — Data drift, prediction drift, model drift detection
  • Anomaly Detection — Z-score based anomaly detection
  • Metric Correlation — Find correlated failure metrics

Phase 10: Multi-Model Orchestration

  • Model Pipelines — Sequential/parallel/conditional/ensemble execution
  • A/B Testing — Multi-model A/B testing with statistics
  • Pipeline Registry — Version and promote entire pipelines
  • Stage Metrics — Track latency and performance per stage

Installation

```bash
pip install pystreamai==0.2.0
```

Note: Wheels-only distribution. Source code is proprietary.

Quick Start

```python
from pystreamai import AutoVersionManager, RollbackStrategy

Automatic versioning

manager = AutoVersionManager()
version_id = manager.deploy_model("sentiment-classifier", model_hash)
manager.promote_version(version_id)

Record metrics and auto-rollback

manager.record_inference("sentiment-classifier", latency=50, error=False)
manager.evaluate_health_windows() # Auto-rollback if degraded

Advanced features

from pystreamai import VersionCostTracker, RollbackOrchestrator
from pystreamai import ModelPipeline, DriftDetector

cost_tracker = VersionCostTracker()
orchestrator = RollbackOrchestrator(manager)
pipeline = ModelPipeline("nlp-pipeline")
detector = DriftDetector()
```

Key Metrics

  • Code: 3,200+ lines of production Python
  • Tests: 23+ comprehensive test cases
  • Documentation: 600+ lines of guides
  • Platforms: TensorFlow, PyTorch, Kubernetes, HuggingFace, extensible

Release Notes

  • ✅ All Phases 5-10 fully implemented
  • ✅ Production-ready code with comprehensive error handling
  • ✅ Full async/await support
  • ✅ Thread-safe operations
  • ✅ Extensive logging and observability
  • ✅ Extensible architecture

System Requirements

  • Python 3.10+
  • macOS (Apple Silicon or Intel)
  • Linux (x86_64 or ARM64)
  • Windows (via WSL2)

Support

Release Date: July 27, 2026
Distribution: Wheels only (no source code)
License: Proprietary

Assets 3
Loading