Skills Astronomer

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

Генерируйте проверенные плейбуки рецептов из AIP с реализациями PR (режим post) или предположительные пользовательские истории из AIP без реализаций (режим pre). Используйте…

agents/skills/airflow

Запрос, управление и устранение неполадок DAG, запусков, задач и системной конфигурации Apache Airflow. Поддерживает более 30 команд для проверки DAG, управления запусками, ведения журналов задач, запросов конфигурации и прямого доступа к REST API. Управление несколькими экземплярами Airflow с постоянной конфигурацией; автоматическое обнаружение локальных и Astro развертываний. Синхронный (с ожиданием завершения) или асинхронный запуск DAG, диагностика сбоев, очистка запусков для повторного выполнения, доступ к журналам задач с фильтрацией по повторным попыткам и индексу карты. Вывод...

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

Шаблон адаптера Airflow для совместимости API v2/v3. Используйте при работе с адаптерами, определением версий или добавлением новых методов API, которые должны работать в разных…

agents/skills/airflow-hitl

Шлюзы утверждения человеком, ввод форм и ветвление в DAG Airflow с использованием отложенных операторов. Четыре типа операторов: ApprovalOperator для решений утвердить/отклонить, HITLOperator для выбора нескольких вариантов с формами, HITLBranchOperator для маршрутизации задач на основе решений человека и HITLEntryOperator для сбора данных из форм. Все операторы являются отложенными, освобождая слоты рабочих узлов в ожидании ответа человека через вкладку Required Actions в интерфейсе Airflow или REST API. Поддерживает дополнительные функции, включая пользовательские...

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

Руководство по реализации совершенно нового языкового SDK для Airflow (AIP-108). Используйте этот навык, когда участник хочет добавить поддержку нового языка программирования —…

agents/skills/airflow-plugins

Создавайте плагины для Airflow 3.1+, которые встраивают приложения FastAPI, пользовательские страницы интерфейса, компоненты React, промежуточное ПО, макросы и ссылки на операторы непосредственно в интерфейс Airflow. Используйте…

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

Добавить или обновить переводы для интерфейса Apache Airflow. Помогает с настройкой локалей, созданием файлов перевода, переводом с учётом региональных особенностей…

agents/skills/analyzing-data

Запрашивайте данные из вашего хранилища данных для ответа на бизнес-вопросы с использованием кэшированных шаблонов и сопоставлений понятий. Поддерживает поиск по шаблонам и кэширование для повторяющихся типов вопросов с записью результатов для улучшения будущих запросов. Включает кэш сопоставлений понятий и таблиц, а также обнаружение схем таблиц через INFORMATION_SCHEMA или grep кодовой базы. Предоставляет функции ядра run_sql() и run_sql_pandas(), возвращающие DataFrames Polars или Pandas для анализа. Команды CLI для управления кэшами понятий, шаблонов и таблиц, а также...

agents/skills/annotating-task-lineage

Аннотирование задач Airflow с помощью data lineage с использованием inlets и outlets. Поддерживает объекты Dataset OpenLineage, Airflow Assets и Airflow Datasets для определения входных и выходных данных в базах данных, хранилищах данных и облачных хранилищах. Используется как запасной вариант, когда операторам не хватает встроенных экстракторов OpenLineage; следует четырехуровневой системе приоритетов, где пользовательские экстракторы и методы OpenLineage имеют приоритет. Включает вспомогательные функции для именования наборов данных для Snowflake, BigQuery, S3 и PostgreSQL для обеспечения согласованности...

agents/skills/authoring-dags

Пошаговый процесс создания DAG Apache Airflow с интеграцией валидации и тестирования. Структурированный шестифазный подход: обнаружение среды и существующих шаблонов, планирование структуры DAG, реализация с соблюдением лучших практик, валидация с помощью команд af CLI, тестирование с согласия пользователя и итеративное исправление. Команды CLI для обнаружения (af config connections, af config providers, af dags list) и валидации (af dags errors, af dags get, af dags explore) обеспечивают немедленную обратную связь по 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

Пишет логику задач Airflow на Java, Kotlin или любом JVM-языке с использованием Airflow Java SDK. Используйте, когда пользователь хочет реализовать задачи Airflow на Java/JVM, спрашивает…

agents/skills/authoring-language-sdk-tasks

Языконезависимая основа для языковых SDK Airflow — реализуйте логику задач на языке, отличном от Python, в то время как DAG остаётся на Python. Используйте, когда пользователь…

agents/skills/blueprint

Определяйте переиспользуемые шаблоны групп задач Airflow с валидацией Pydantic и составляйте DAG из YAML. Используйте при создании шаблонов blueprint, составлении DAG из…

astronomer/.agents/skills/chart-tests

Используйте при написании, редактировании, рецензировании или запуске тестов Helm-чартов для репозитория Astronomer APC. Охватывает шаблоны pytest, использование render_chart(), подчарты…

agents/skills/checking-freshness

Проверяет свежесть данных, сравнивая временные метки таблиц и шаблоны обновлений со шкалой устаревания. Определяет столбцы с временными метками, используя распространённые шаблоны именования ETL (_loaded_at, _updated_at, created_at и т.д.), и запрашивает их максимальные значения для определения возраста. Классифицирует данные по четырём статусам свежести: Свежие (< 4 часов), Устаревшие (4–24 часа), Очень устаревшие (> 24 часов) или Неизвестно (временная метка не найдена). Предоставляет SQL-шаблоны для проверки времени последнего обновления и тенденций количества строк за последние дни, чтобы...

astronomer/.agents/skills/circleci

Используйте при написании, редактировании или проверке конфигурации CircleCI для репозитория Astronomer APC. Охватывает организацию скриптов, встроенные и внешние скрипты, а также…

agents/skills/configuring-airflow-language-sdks

Настраивает Airflow для выполнения задач языковых SDK (Go и будущих нативных SDK) — регистрирует координатор, сопоставляет очередь с ним, обеспечивает наличие среды выполнения/артефакта на рабочих узлах,…

agents/skills/cosmos-dbt-core

Преобразуйте проекты dbt Core в DAG или TaskGroups Airflow с помощью Astronomer Cosmos. Поддерживает три шаблона сборки: автономный DbtDag, DbtTaskGroup в существующих DAG и отдельные операторы Cosmos для тонкой настройки. Выберите один из восьми режимов выполнения (WATCHER, LOCAL, VIRTUALENV, KUBERNETES, AIRFLOW_ASYNC и другие) в зависимости от требований к изоляции и производительности. Предлагает три стратегии парсинга (dbt_manifest, dbt_ls, dbt_ls_file, automatic) для балансировки скорости и сложности селекторов...

agents/skills/cosmos-dbt-fusion

Настройка Astronomer Cosmos для проектов dbt Fusion на Snowflake, Databricks, BigQuery или Redshift с локальным выполнением. Требуется Cosmos 1.11.0+, отдельная установка бинарного файла dbt Fusion в среде выполнения Airflow и ExecutionMode.LOCAL с вызовом подпроцесса. Поддерживает три стратегии парсинга: dbt_manifest (самая быстрая для крупных проектов), dbt_ls (для сложных селекторов) или автоматическая (для простых конфигураций). Охватывает настройку ProfileConfig для подключения к хранилищам, ProjectConfig для путей к проектам dbt и...

agents/skills/creating-openlineage-extractors

Пользовательские экстракторы OpenLineage для неподдерживаемых операторов Airflow и сложных сценариев происхождения данных. Два подхода: добавление методов OpenLineage непосредственно в операторы, которыми вы владеете (рекомендуется), или создание пользовательских экстракторов для сторонних операторов, которые вы не можете изменить. Экстракторы перехватывают выполнение оператора в трех точках: перед выполнением для статического происхождения, после успешного выполнения для определения выходных данных во время выполнения и опционально после сбоя для частичного происхождения. Регистрируйте экстракторы через airflow.cfg или переменные окружения...

agents/skills/dag-factory

Автор Apache Airflow DAGs декларативно с помощью YAML-конфигураций dag-factory. Используйте при создании шаблонов dag-factory, компоновке DAG из YAML для dag-factory,…

agents/skills/debugging-dags

Систематический анализ первопричин и устранение неисправностей для упавших DAG-графов Airflow с использованием структурированных рабочих процессов расследования. Проводит через четырехэтапный процесс диагностики: выявление сбоя, извлечение деталей ошибки, сбор контекстной информации и предоставление практических шагов по исправлению. Классифицирует сбои на четыре типа (данные, код, инфраструктура, зависимости) для фокусировки расследования и предложения соответствующих исправлений. Предоставляет готовые к использованию команды CLI для извлечения журналов, сравнения запусков, очистки задач и 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

Развертывание DAG-файлов и проектов Airflow. Используйте, когда пользователь хочет развернуть код, отправить DAG-файлы, настроить CI/CD, выполнить развертывание в рабочей среде или спрашивает о стратегиях развертывания…

agents/skills/deploying-go-sdk-bundles

Собирает, упаковывает и развёртывает скомпилированные пакеты Airflow Go SDK, чтобы ExecutableCoordinator мог их запускать. Используйте, когда пользователь хочет скомпилировать пакет задач Go, спрашивает…

agents/skills/deploying-java-sdk-bundles

Собирает и развертывает скомпилированные пакеты Airflow Java SDK, чтобы воркеры могли их запускать. Используйте, когда пользователь хочет упаковать JVM-пакет задач в JAR, спрашивает о…

agents/skills/discovering-data

Обнаружение и исследование данных по концепции или области. Используйте, когда пользователь спрашивает, какие данные существуют по теме (например, «ARR», «клиенты», «заказы»), хочет найти…