Skills de Astronomer

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

Gere playbooks de receitas verificados a partir de AIPs com implementações de PR (modo post), ou histórias de usuário especulativas a partir de AIPs sem implementações (modo pre). Use…

agents/skills/airflow

Consulte, gerencie e solucione problemas de DAGs, execuções, tarefas e configuração de sistema do Apache Airflow. Suporta mais de 30 comandos para inspeção de DAGs, gerenciamento de execuções, registro de tarefas, consultas de configuração e acesso direto à API REST. Gerencie múltiplas instâncias do Airflow com configuração persistente; descubra automaticamente implantações locais e Astro. Dispare execuções de DAG de forma síncrona (aguardando conclusão) ou assíncrona, diagnostique falhas, limpe execuções para repetição e acesse logs de tarefas com filtragem por repetição/índice de mapa. Saída...

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

Padrão de adaptador Airflow para compatibilidade com APIs v2/v3. Use ao trabalhar com adaptadores, detecção de versão ou ao adicionar novos métodos de API que precisam funcionar em…

agents/skills/airflow-hitl

Portões de aprovação humana, entradas de formulário e ramificações em DAGs do Airflow usando operadores adiáveis. Quatro tipos de operadores: ApprovalOperator para decisões de aprovar/rejeitar, HITLOperator para seleção de múltiplas opções com formulários, HITLBranchOperator para roteamento de tarefas orientado por humanos e HITLEntryOperator para coleta de dados de formulário. Todos os operadores são adiáveis, liberando slots de worker enquanto aguardam resposta humana via a aba Ações Necessárias da interface do Airflow ou API REST. Suporta recursos opcionais incluindo personalização...

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

Guia para implementar um SDK de linguagem totalmente novo para o Airflow (AIP-108). Use esta habilidade quando um contribuidor quiser adicionar suporte para uma nova linguagem de programação —…

agents/skills/airflow-plugins

Crie plugins do Airflow 3.1+ que incorporam aplicativos FastAPI, páginas de UI personalizadas, componentes React, middleware, macros e links de operador diretamente na interface do Airflow. Use…

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

Adicionar ou atualizar traduções para a interface do Apache Airflow. Orienta sobre a configuração de locales, criação de arquivos de tradução, tradução com especificidades de localidade…

agents/skills/analyzing-data

Consulte seu data warehouse para responder perguntas de negócios com padrões em cache e mapeamentos de conceitos. Suporta busca de padrões e cache para tipos de perguntas repetidas, com registro de resultados para melhorar consultas futuras. Inclui cache de mapeamento conceito-tabela e descoberta de esquemas de tabela via INFORMATION_SCHEMA ou grep no código-fonte. Fornece funções de kernel run_sql() e run_sql_pandas() que retornam DataFrames Polars ou Pandas para análise. Comandos CLI para gerenciar caches de conceitos, padrões e tabelas, além de...

agents/skills/annotating-task-lineage

Anotar tarefas do Airflow com linhagem de dados usando inlets e outlets. Suporta objetos OpenLineage Dataset, Assets do Airflow e Datasets do Airflow para definir entradas e saídas em bancos de dados, data warehouses e armazenamento em nuvem. Use como fallback quando operadores não possuem extratores OpenLineage integrados; segue um sistema de precedência de quatro níveis onde extratores personalizados e métodos OpenLineage têm prioridade. Inclui auxiliares de nomenclatura de datasets para Snowflake, BigQuery, S3 e PostgreSQL para garantir consistência...

agents/skills/authoring-dags

Fluxo de trabalho guiado para criação de DAGs do Apache Airflow com integração de validação e testes. Abordagem estruturada em seis fases: descobrir o ambiente e padrões existentes, planejar a estrutura da DAG, implementar seguindo as melhores práticas, validar com comandos da CLI af, testar com consentimento do usuário e iterar em correções. Comandos da CLI para descoberta (af config connections, af config providers, af dags list) e validação (af dags errors, af dags get, af dags explore) fornecem feedback imediato sobre a 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

Escreve a lógica de tarefas do Airflow em Java, Kotlin ou qualquer linguagem JVM usando o Airflow Java SDK. Use quando o usuário quiser implementar tarefas do Airflow em Java/JVM, pedir…

agents/skills/authoring-language-sdk-tasks

A base neutra em termos de linguagem para os SDKs de linguagem do Airflow — implemente a lógica de tarefas em uma linguagem que não seja Python enquanto o DAG permanece em Python. Use quando o usuário…

agents/skills/blueprint

Defina modelos reutilizáveis de grupos de tarefas do Airflow com validação Pydantic e componha DAGs a partir de YAML. Use ao criar modelos de blueprint, compor DAGs a partir de…

astronomer/.agents/skills/chart-tests

Use ao escrever, editar, revisar ou executar testes de chart Helm para o repositório Astronomer APC. Abrange padrões pytest, uso de render_chart(), sub-chart…

agents/skills/checking-freshness

Verifique a atualização dos dados analisando os timestamps das tabelas e os padrões de atualização em relação a uma escala de obsolescência. Identifica colunas de timestamp usando padrões comuns de nomenclatura ETL (_loaded_at, _updated_at, created_at, etc.) e consulta seus valores máximos para determinar a idade. Classifica os dados em quatro status de atualização: Atualizados (< 4 horas), Desatualizados (4–24 horas), Muito Desatualizados (> 24 horas) ou Desconhecido (nenhum timestamp encontrado). Fornece modelos SQL para verificar o horário da última atualização e as tendências de contagem de linhas nos dias recentes para...

astronomer/.agents/skills/circleci

Use ao escrever, editar ou revisar a configuração do CircleCI para o repositório Astronomer APC. Abrange organização de scripts, scripts inline vs externos e…

agents/skills/configuring-airflow-language-sdks

Configura o Airflow para executar tarefas de SDK de linguagem (Go e futuros SDKs nativos) — registra um coordenador, mapeia uma fila para ele, garante o runtime/artefato nos workers,…

agents/skills/cosmos-dbt-core

Converta projetos dbt Core em DAGs ou TaskGroups do Airflow usando o Astronomer Cosmos. Suporta três padrões de montagem: DbtDag independente, DbtTaskGroup dentro de DAGs existentes e operadores Cosmos individuais para controle refinado. Escolha entre oito modos de execução (WATCHER, LOCAL, VIRTUALENV, KUBERNETES, AIRFLOW_ASYNC e outros) com base nas necessidades de isolamento e desempenho. Oferece três estratégias de parsing (dbt_manifest, dbt_ls, dbt_ls_file, automática) para equilibrar velocidade e complexidade do seletor...

agents/skills/cosmos-dbt-fusion

Configure o Astronomer Cosmos para projetos dbt Fusion no Snowflake, Databricks, BigQuery ou Redshift com execução local. Requer Cosmos 1.11.0+, binário dbt Fusion instalado separadamente no runtime do Airflow e ExecutionMode.LOCAL com invocação de subprocesso. Suporta três estratégias de parsing: dbt_manifest (mais rápida para projetos grandes), dbt_ls (para seletores complexos) ou automática (configurações simples). Abrange configuração de ProfileConfig para conexões de warehouse, ProjectConfig para caminhos de projetos dbt e...

agents/skills/creating-openlineage-extractors

Extratores OpenLineage personalizados para operadores Airflow não suportados e cenários complexos de linhagem. Duas abordagens: adicionar métodos OpenLineage diretamente aos operadores que você possui (recomendado), ou criar extratores personalizados para operadores de terceiros que você não pode modificar. Os extratores interceptam a execução do operador em três pontos: antes da execução para linhagem estática, após o sucesso para saídas determinadas em tempo de execução e, opcionalmente, após falha para linhagem parcial. Registre os extratores via airflow.cfg ou ambiente...

agents/skills/dag-factory

Crie DAGs do Apache Airflow de forma declarativa com configurações YAML do dag-factory. Use ao criar templates do dag-factory, compondo DAGs a partir de YAML para o dag-factory,…

agents/skills/debugging-dags

Análise sistemática de causa raiz e remediação para DAGs do Airflow com falhas, utilizando fluxos de investigação estruturados. Orienta por um processo de diagnóstico em quatro etapas: identificar a falha, extrair detalhes do erro, reunir informações contextuais e fornecer etapas de remediação acionáveis. Classifica as falhas em quatro tipos (dados, código, infraestrutura, dependência) para focar a investigação e sugerir correções apropriadas. Fornece comandos CLI prontos para recuperação de logs, comparação de execuções, limpeza de tarefas e DAG...

agents/skills/delegating-to-otto

Direciona o agente Otto da

agents/skills/deploying-airflow

Implantar DAGs e projetos do Airflow. Use quando o usuário quiser implantar código, enviar DAGs, configurar CI/CD, implantar em produção ou perguntar sobre estratégias de implantação…

agents/skills/deploying-go-sdk-bundles

Compila, empacota e implanta pacotes compilados do Airflow Go SDK para que o ExecutableCoordinator possa executá-los. Use quando o usuário quiser compilar um pacote de tarefas Go, pedir…

agents/skills/deploying-java-sdk-bundles

Cria e implanta bundles compilados do SDK Java do Airflow para que os workers possam executá-los. Use quando o usuário quiser empacotar um bundle de tarefa JVM em um JAR, perguntar sobre o…

agents/skills/discovering-data

Descubra e explore dados para um conceito ou domínio. Use quando o usuário perguntar quais dados existem para um tópico (ex.: "ARR", "clientes", "pedidos"), quiser encontrar…