Distributed systems architect and creator of the Wisrovi Suite (34 tools & official PyPI packages). Scientific researcher with 26 preprints indexed with CERN/Zenodo DOIs in Forensic Explainable AI (XAI), Conformal Prediction, and Agentic Formal Verification with LTL.
Scalable enterprise MLOps platforms (wyoloservice / NeuralForgeAI), GPU Celery queues, and reactive microservices.
34 independent, modular libraries and tools centered around the wpipe gravitational core, WPipe Studio visual IDE, and 10 official FastMCP servers.
26 preprints with official CERN/Zenodo DOIs & verified ORCID. Mathematical rigor in causality, bootstrap bounds, and LTL.
Visual architecture spanning two synchronized gravitational systems: the Main Universe with wpipe as the central Sun coordinating persistence, messaging, and distributed MLOps; and the Agentic Constellation where the AI Agent Hub orbits with 6 official FastMCP servers for seamless LLM interactions.
wpipe as the central Sun coordinating streaming, transactional persistence, Zero Trust security, and distributed cluster training.
Autonomous agentic core powered by the official FastMCP Servers for Claude, Cursor, and Antigravity.
The visual block-programming environment for the wpipe ecosystem. Design reactive data & AI pipelines by snapping visual blocks without writing code (100% No-Code), and compile with a single click into world-class production Python code (Pro-Code), FastAPI microservices, and automated tests. Zero vendor lock-in.
WPipe code adhering to top global engineering standards—audit-ready and Git-native from day one.pytest test suites in one step.Enterprise-grade distributed MLOps platform for Computer Vision architectures (YOLOv8, YOLOv11, YOLO26) featuring evolutionary optimization via Optuna TPESampler and forensic Explainable AI audits.
My research agenda combines formal mathematical rigor with mission-critical software engineering. Holding a Master's degree in Artificial Intelligence (VIU, Spain) and a Bachelor's in Electronic Engineering (UDI, Colombia), I pursue doctoral research across three primary frontiers:
Preprints experimentally investigate MLOps scalability, FID latent domain shift quantification, multi-scale Grad-CAM forensic audits, and formal verification in heterogeneous clusters.
All 34 official suite packages, tools and FastMCP servers actively maintained and installable via the automated w-cli terminal suite.
Visual Pipeline Canvas & IDE Extension. Scratch/Blockly-style node graph editor with automated DAG compilation, live telemetry and native wpipe-engine execution.
High-performance Python pipeline orchestrator (Sync/Async). Declarative DAG core engine with real GIL-bypass parallelism, SQLite WAL checkpoints, and contextual dependency injection.
Decorator-based high-throughput wrapper for Apache Kafka. Non-blocking consumers/producers with automated reconnection, thread pools, and backpressure handling.
Ultra-fast Redis sync/async integration & caching suite. Connection pooling, token-bucket distributed rate limiters, pub/sub streams, and atomic distributed locks.
Reusable high-level decorator suite. Implements exponential backoff with full jitter, runtime latency profiling, memory tracing, and structured Loguru logging.
Official FastMCP Server for wpipe pipeline architecture. Enables LLM agents (Claude, Cursor, Antigravity) to design, inspect, formally verify, and dry-run DAG execution flows.
High-concurrency PostgreSQL connection pooler and enterprise ORM mapper. Thread-safe connection pools, ACID transaction decorators, and Pydantic model synchronization.
Official catalog of production-ready modular steps for wpipe. Pre-built, strongly typed steps for data ingestion, ETL, computer vision, and ML transformations.
High-performance SQLite ORM wrapper featuring reactive TableSync. Optimized multi-thread Write-Ahead Logging (WAL) mode, connection pooling, and automated schema migration.
Complete lifecycle training wrapper for YOLO (v8, v11, YOLO26) and RT-DETR. Seamless synchronization of weights to MinIO S3 and real-time metric logging to MLflow.
FastMCP Server for NeuralForgeAI YOLO cluster orchestration. Enables LLMs to validate datasets, generate Sweeper v2 configurations, inspect GPU queues, and dispatch Optuna sweeps.
Cryptographic secrets encryption vault locked to host hardware fingerprints (machine-salted). AES-256 Fernet symmetric encryption protecting sensitive cluster configurations.
Industrial Zero Trust security architecture for Hyperledger Fabric networks. ECDSA P-256 digital signature validation, SHA-256 code integrity hashing, and cryptographic audits.
Scikit-learn compatible transformers for audio feature extraction (Mel spectrograms, MFCC, FFT spectral centroid) and real-time acoustic data augmentation pipelines.
High-throughput ClickHouse ORM mapping using clickhouse-connect. Optimized for bulk batch insertions, columnar time-series aggregation, and deep learning inference telemetry.
Docker SDK automation engine: ephemeral container spawner, GPU VRAM & CPU quota enforcement governors, and embedded Trivy vulnerability scanning.
Reactive MongoDB document mapper utilizing Pydantic models. Features automatic query caching on wredis, safe aggregation pipelines, and lifecycle event listeners.
FastMCP Server for Kafka event streaming and topic inspection. Exposes tools for LLM agents to monitor topic partitions, consumer group lag, and inject telemetry payloads.
FastMCP Server for Redis cache management and memory profiling. Enables AI agents to safely query keys, inspect data structures, and monitor memory fragmentation.
FastMCP Server for PostgreSQL enterprise databases. Gives LLM agents safe, parameterized query tools, schema inspection capabilities, and role permission validation.
FastMCP Server for SQLite database inspection and queries. Parametric safe queries, index statistics analysis, and audit state extraction for wpipe pipelines.
Community-driven plugin repository and hot-reloadable extension framework for wpipe. Dynamic dependency isolation for custom enterprise pipelines.
Essential script scheduling and validation helpers. Robust cron expression parser, dataset format verification, and algorithmic data normalization.
Core foundational Python types, algorithms, and mathematical structures shared across all packages in the wisrovi ecosystem. Optimized for inference efficiency.
TinyDB Pydantic document mapper and lightweight query suite. Zero-config embedded document persistence for edge and microservice state.
Official FastMCP Server for WTinyDB. Provides autonomous LLM agents with structured document retrieval, table inspection, and state queries.
High-throughput Milvus vector database client and similarity search suite. Distributed embeddings indexing, collection management, and cosine/L2 distance search.
Official FastMCP Server for Milvus. Equips AI agents with vector collection querying, hybrid dense/sparse search, and semantic similarity tooling.
High-throughput MySQL Pydantic ORM wrapper. Connection pooling, declarative migrations, schema verification, and transactional consistency.
Enterprise MariaDB connection pooling and query builder. High-availability cluster routing, Pydantic model serialization, and thread-safe operations.
Official FastMCP Server for MariaDB. Enables autonomous LLM agents to inspect database catalogs, query tables, and diagnose replication status.
Official FastMCP Server for ClickHouse. Exposes columnar analytical queries, real-time log exploration, and aggregation benchmarks to AI agents.
Dynamic Snowflake SQL client and schema mapper. Managed data warehouse queries, async cursor fetch, and Arrow/Pandas DataFrame extraction.
Enterprise messaging library with Telegram and Slack integration. Automated pipeline alerts, bot commands, and resilient webhook dispatchers.
Install and manage any of the 34 official suite libraries and tools with a single interactive terminal interface: