[05] // RUMBO · GRAFO TÉCNICO DE APRENDIZAJE

Aprende Conceptos, No Modas de Herramientas.

Orquestación o modelado dimensional son los conceptos; Airflow, dbt o DuckDB son formas de practicarlos. Rumbo organiza 34 nodos en un grafo topológico dependiente, conectado en tiempo real al pipeline de releases y respaldado por fallos reales en producción.

34 Nodos en DAG·18 Casos "Lo vi romperse"·100% Datos en Vivo
main // postmortem
Lo Vi Romperse
Concepto:Manejo de Errores vs Descarte Silencioso
Tool:Python (Worker)a8f3f85
54  for release in raw_releases:
55- if not release.version or not release.date:
56- continue # Silencioso: omitía sin log
55+ if not release.version or not release.date:
56+ logger.warning("invalid_release", raw=release.tag)
57+ quarantine.append(release) # Con rastro
58  yield process_valid_release(release)
Bitácora:Un descarte silencioso es peor que un except: la corrida terminaba en verde engañoso sin datos.
Kahn DAG Verified · Nodo 02.1
Ver en el grafo
[05.1] // GENERADOR DETERMINISTA DE SUBGRAFO

Armáturumbopersonalizado

Dos preguntas. La ruta sale del grafo topológico según dependencias técnicas reales, no de una plantilla ni de un LLM: mismas respuestas, misma ruta.

[Paso 1]¿Hasta dónde querés llegar?
[Paso 2]¿De dónde arrancás?
Configuración Activa
Sin Alucinaciones
Objetivo:
Construir pipelines batch confiables
Partida:
Desde cero

Sin auth ni registros · Genera una URL canónica y compartible

[05.2] // GRAFO COMPLETO DE DEPENDENCIAS

ElGrafoCompleto

Los 34 nodos ordenados topológicamente por nivel y prerequisitos, conectados a los datos vivos del pipeline. Explora la ruta en formato de IDE con árbol de archivos, navega el Grafo interactivo de Obsidian o inspecciona las fichas técnicas.

Mostrando 34 de 34 nodos
idempotencia.concept
concepto
// NODO [02.2]·Ingesta

Idempotencia

// 01. QUÉ RESUELVE

Correr el mismo proceso dos veces tiene que dejar el mismo estado. Sin esto, un reintento duplica datos y un backfill corrompe el histórico en vez de repararlo.

02. Criterio de Dominio: Lo dominás cuando

Podés correr tu pipeline dos veces seguidas y comprobar que el estado de la base es idéntico, y sabés decir cuál es la clave que lo garantiza.

// 03. CASO DE PRODUCCIÓN (LO VI ROMPERSE)
Incidente de Producción Verificado
Ver commit / postmortem

El hash de contenido se calculaba sobre el JSON crudo de GitHub, que trae download_count por asset. Cambiaba con que alguien descargara un archivo, sin release nuevo, así que cada corrida guardaba una fila nueva. La garantía tiene que vivir en un constraint, no en la disciplina del código que escribe.

// 04. TOPOLOGÍA DEL GRAFO (DAG)
Requiere antes (1):
Desbloquea después (3):
// 05. IMPLEMENTACIONES CONECTADAS AL PIPELINE
dbtv2.0.0-dev.41-test-pypi
// 06. DÓNDE APRENDERLO (FUENTES CON CRITERIO)