Skills de Astronomer

airflow/.agents/skills/aip-user-stories

Generar libros de jugadas de recetas verificadas a partir de AIPs con implementaciones de PR (modo post), o historias de usuario especulativas a partir de AIPs sin implementaciones (modo pre). Usar…

agents/skills/airflow

Consulta, gestiona y soluciona problemas de DAGs, ejecuciones, tareas y configuración del sistema de Apache Airflow. Soporta más de 30 comandos para inspección de DAGs, gestión de ejecuciones, registro de tareas, consultas de configuración y acceso directo a la API REST. Administra múltiples instancias de Airflow con configuración persistente; descubre automáticamente implementaciones locales y de Astro. Ejecuta DAGs de forma síncrona (esperando su finalización) o asíncrona, diagnostica fallos, limpia ejecuciones para reintentos y accede a registros de tareas con filtros de reintento e índice de mapa. Salida...

agents/astro-airflow-mcp/.claude/skills/airflow-adapter

Patrón de adaptador de Airflow para compatibilidad con API v2/v3. Úselo al trabajar con adaptadores, detección de versiones o agregar nuevos métodos de API que necesiten funcionar en…

agents/skills/airflow-hitl

Compuertas de aprobación humana, entradas de formulario y ramificación en DAGs de Airflow utilizando operadores diferibles. Cuatro tipos de operadores: ApprovalOperator para decisiones de aprobar/rechazar, HITLOperator para selección de múltiples opciones con formularios, HITLBranchOperator para enrutamiento de tareas impulsado por humanos y HITLEntryOperator para recopilación de datos de formularios. Todos los operadores son diferibles, liberando espacios de trabajo mientras esperan respuesta humana a través de la pestaña de Acciones Requeridas de la interfaz de usuario de Airflow o la API REST. Soporta características opcionales que incluyen personalización...

airflow/.agents/skills/airflow-java-sdk

Guide for contributing to the Airflow Java SDK (AIP-108). Use this skill whenever a contributor is working in the `java-sdk/` directory or on the Java…

airflow/.agents/skills/airflow-new-sdk

Guía para implementar un SDK de lenguaje completamente nuevo para Airflow (AIP-108). Usa esta habilidad cuando un colaborador quiera agregar soporte para un nuevo lenguaje de programación —…

agents/skills/airflow-plugins

Crea plugins de Airflow 3.1+ que integren aplicaciones FastAPI, páginas de UI personalizadas, componentes React, middleware, macros y enlaces de operadores directamente en la interfaz de Airflow. Usa…

agents/skills/airflow-state-store

Persists task and asset state across retries and DAG runs using Airflow 3.3's AIP-103 key/value stores (`task_state_store`, `asset_state_store`) and the…

airflow/.agents/skills/airflow-translations

Añadir o actualizar traducciones para la interfaz de Apache Airflow. Guía a través de la configuración de locales, la creación de archivos de traducción, la traducción con especificidad de configuración regional…

agents/skills/analyzing-data

Consulta tu almacén de datos para responder preguntas de negocio con patrones en caché y mapeos de conceptos. Soporta búsqueda de patrones y almacenamiento en caché para tipos de preguntas repetidas, con registro de resultados para mejorar consultas futuras. Incluye caché de mapeo concepto-tabla y descubrimiento de esquemas de tablas mediante INFORMATION_SCHEMA o búsqueda en el código base. Proporciona funciones kernel run_sql() y run_sql_pandas() que devuelven DataFrames de Polars o Pandas para análisis. Comandos CLI para gestionar cachés de conceptos, patrones y tablas, además de...

agents/skills/annotating-task-lineage

Anotar tareas de Airflow con linaje de datos utilizando inlets y outlets. Soporta objetos Dataset de OpenLineage, Assets de Airflow y Datasets de Airflow para definir entradas y salidas en bases de datos, almacenes de datos y almacenamiento en la nube. Úselo como alternativa cuando los operadores carezcan de extractores OpenLineage integrados; sigue un sistema de precedencia de cuatro niveles donde los extractores personalizados y los métodos OpenLineage tienen prioridad. Incluye ayudantes de nomenclatura de datasets para Snowflake, BigQuery, S3 y PostgreSQL para garantizar consistencia...

agents/skills/authoring-dags

Flujo de trabajo guiado para crear DAGs de Apache Airflow con integración de validación y pruebas. Enfoque estructurado de seis fases: descubrir el entorno y patrones existentes, planificar la estructura del DAG, implementar siguiendo las mejores prácticas, validar con comandos de la CLI de af, probar con consentimiento del usuario, e iterar sobre correcciones. Los comandos de la CLI para descubrimiento (af config connections, af config providers, af dags list) y validación (af dags errors, af dags get, af dags explore) proporcionan retroalimentación inmediata sobre el DAG...

agents/skills/authoring-go-sdk-tasks

Writes Airflow task logic in Go using the Airflow Go SDK. Use when the user wants to implement Airflow tasks in Go, asks about `BundleProvider`/`RegisterDags`,…

agents/skills/authoring-java-sdk-tasks

Escribe la lógica de tareas de Airflow en Java, Kotlin o cualquier lenguaje JVM usando el SDK de Java de Airflow. Úsalo cuando el usuario quiera implementar tareas de Airflow en Java/JVM, pregunte…

agents/skills/authoring-language-sdk-tasks

La base neutral en cuanto al lenguaje para los SDKs de idiomas de Airflow: implementa la lógica de tareas en un lenguaje que no sea Python mientras el DAG permanece en Python. Úsalo cuando el usuario…

agents/skills/blueprint

Define plantillas reutilizables de grupos de tareas de Airflow con validación Pydantic y componga DAGs desde YAML. Úselo al crear plantillas de blueprint, componer DAGs desde…

astronomer/.agents/skills/chart-tests

Úsalo al escribir, editar, revisar o ejecutar pruebas de gráficos Helm para el repositorio Astronomer APC. Cubre patrones de pytest, uso de render_chart(), sub-gráficos…

agents/skills/checking-freshness

Verifica la frescura de los datos revisando las marcas de tiempo de las tablas y los patrones de actualización frente a una escala de obsolescencia. Identifica columnas de marca de tiempo usando patrones comunes de nomenclatura ETL (_loaded_at, _updated_at, created_at, etc.) y consulta sus valores máximos para determinar la antigüedad. Clasifica los datos en cuatro estados de frescura: Fresco (< 4 horas), Obsoleto (4–24 horas), Muy obsoleto (> 24 horas) o Desconocido (sin marca de tiempo encontrada). Proporciona plantillas SQL para verificar la última hora de actualización y las tendencias de recuento de filas en días recientes para...

astronomer/.agents/skills/circleci

Úsalo al escribir, editar o revisar la configuración de CircleCI para el repositorio Astronomer APC. Cubre la organización de scripts, scripts inline vs externos, y…

agents/skills/configuring-airflow-language-sdks

Configura Airflow para ejecutar tareas de SDK de lenguaje (Go y futuros SDK nativos): registrar un coordinador, asignarle una cola, garantizar el runtime/artefacto en los workers,…

agents/skills/cosmos-dbt-core

Convierte proyectos de dbt Core en DAGs o TaskGroups de Airflow usando Astronomer Cosmos. Soporta tres patrones de ensamblaje: DbtDag independiente, DbtTaskGroup dentro de DAGs existentes y operadores individuales de Cosmos para control detallado. Elige entre ocho modos de ejecución (WATCHER, LOCAL, VIRTUALENV, KUBERNETES, AIRFLOW_ASYNC y otros) según las necesidades de aislamiento y rendimiento. Ofrece tres estrategias de análisis (dbt_manifest, dbt_ls, dbt_ls_file, automática) para equilibrar velocidad y complejidad de selectores...

agents/skills/cosmos-dbt-fusion

Configura Astronomer Cosmos para proyectos de dbt Fusion en Snowflake, Databricks, BigQuery o Redshift con ejecución local. Requiere Cosmos 1.11.0+, el binario de dbt Fusion instalado por separado en el entorno de Airflow, y ExecutionMode.LOCAL con invocación de subprocesos. Soporta tres estrategias de análisis: dbt_manifest (la más rápida para proyectos grandes), dbt_ls (para selectores complejos) o automática (configuraciones simples). Cubre la configuración de ProfileConfig para conexiones de almacenes, ProjectConfig para rutas de proyectos de dbt y...

agents/skills/creating-openlineage-extractors

Extractores personalizados de OpenLineage para operadores de Airflow no soportados y escenarios complejos de linaje. Dos enfoques: agregar métodos de OpenLineage directamente a los operadores que posees (recomendado), o crear extractores personalizados para operadores de terceros que no puedes modificar. Los extractores interceptan la ejecución del operador en tres puntos: antes de la ejecución para linaje estático, después del éxito para salidas determinadas en tiempo de ejecución, y opcionalmente después del fallo para linaje parcial. Registra los extractores mediante airflow.cfg o variables de entorno...

agents/skills/dag-factory

Crea DAGs de Apache Airflow de forma declarativa con configuraciones YAML de dag-factory. Úsalo al crear plantillas de dag-factory, componer DAGs desde YAML para dag-factory,…

agents/skills/debugging-dags

Análisis sistemático de causa raíz y remediación para DAGs de Airflow fallidos con flujos de trabajo de investigación estructurados. Guía a través de un proceso de diagnóstico de cuatro pasos: identificar la falla, extraer detalles del error, recopilar información contextual y entregar pasos de remediación accionables. Clasifica las fallas en cuatro tipos (datos, código, infraestructura, dependencia) para enfocar la investigación y sugerir correcciones apropiadas. Proporciona comandos CLI listos para usar para recuperación de registros, comparación de ejecuciones, limpieza de tareas y DAG...

agents/skills/delegating-to-otto

Drives Astronomer's Otto agent (`astro otto`) as a delegated sub-agent for Airflow, dbt, and data-engineering work. Use when the user explicitly asks to "use…

agents/skills/deploying-airflow

Desplegar DAGs y proyectos de Airflow. Úsalo cuando el usuario quiera desplegar código, enviar DAGs, configurar CI/CD, desplegar a producción, o pregunte sobre estrategias de despliegue…

agents/skills/deploying-go-sdk-bundles

Compila, empaqueta e implementa paquetes compilados del SDK de Airflow Go para que ExecutableCoordinator pueda ejecutarlos. Úsalo cuando el usuario quiera compilar un paquete de tareas de Go, solicite…

agents/skills/deploying-java-sdk-bundles

Compila e implementa paquetes compilados del SDK de Java de Airflow para que los workers puedan ejecutarlos. Úsalo cuando el usuario quiera empaquetar un paquete de tareas JVM en un JAR, pregunte sobre el…

agents/skills/discovering-data

Descubrir y explorar datos para un concepto o dominio. Úsalo cuando el usuario pregunte qué datos existen para un tema (por ejemplo, "ARR", "clientes", "pedidos"), quiera encontrar…