Skills Astronomer

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

Hasilkan buku resep playbook yang terverifikasi dari AIP dengan implementasi PR (mode post), atau cerita pengguna spekulatif dari AIP tanpa implementasi (mode pre). Gunakan…

agents/skills/airflow

Kueri, kelola, dan pecahkan masalah DAG, proses, tugas, serta konfigurasi sistem Apache Airflow. Mendukung 30+ perintah untuk inspeksi DAG, manajemen proses, pencatatan tugas, kueri konfigurasi, dan akses langsung REST API. Kelola beberapa instance Airflow dengan konfigurasi persisten; temukan secara otomatis deployment lokal dan Astro. Jalankan proses DAG secara sinkron (tunggu hingga selesai) atau asinkron, diagnosis kegagalan, hapus proses untuk percobaan ulang, dan akses log tugas dengan filter percobaan ulang/indeks peta. Keluaran...

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

Pola adaptor Airflow untuk kompatibilitas API v2/v3. Gunakan saat bekerja dengan adaptor, deteksi versi, atau menambahkan metode API baru yang perlu berfungsi di berbagai…

agents/skills/airflow-hitl

Gerbang persetujuan manusia, input formulir, dan percabangan dalam DAG Airflow menggunakan operator yang dapat ditunda. Empat jenis operator: ApprovalOperator untuk keputusan setuju/tolak, HITLOperator untuk pemilihan multi-opsi dengan formulir, HITLBranchOperator untuk perutean tugas yang digerakkan manusia, dan HITLEntryOperator untuk pengumpulan data formulir. Semua operator dapat ditunda, membebaskan slot pekerja sambil menunggu respons manusia melalui tab Required Actions di UI Airflow atau REST API. Mendukung fitur opsional termasuk kustom...

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

Panduan untuk mengimplementasikan SDK bahasa pemrograman yang benar-benar baru untuk Airflow (AIP-108). Gunakan keterampilan ini ketika kontributor ingin menambahkan dukungan untuk bahasa pemrograman baru —…

agents/skills/airflow-plugins

Bangun plugin Airflow 3.1+ yang menyematkan aplikasi FastAPI, halaman UI kustom, komponen React, middleware, makro, dan tautan operator langsung ke dalam UI Airflow. Gunakan…

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

Menambahkan atau memperbarui terjemahan untuk antarmuka Apache Airflow. Memandu dalam menyiapkan lokal, menyusun file terjemahan, menerjemahkan dengan spesifik lokal…

agents/skills/analyzing-data

Kueri gudang data Anda untuk menjawab pertanyaan bisnis dengan pola yang di-cache dan pemetaan konsep. Mendukung pencarian pola dan caching untuk jenis pertanyaan berulang, dengan pencatatan hasil untuk meningkatkan kueri di masa mendatang. Menyertakan cache pemetaan konsep-ke-tabel dan penemuan skema tabel melalui INFORMATION_SCHEMA atau grep basis kode. Menyediakan fungsi kernel run_sql() dan run_sql_pandas() yang mengembalikan DataFrame Polars atau Pandas untuk analisis. Perintah CLI untuk mengelola cache konsep, pola, dan tabel, plus...

agents/skills/annotating-task-lineage

Anotasi tugas Airflow dengan lineage data menggunakan inlet dan outlet. Mendukung objek Dataset OpenLineage, Aset Airflow, dan Dataset Airflow untuk mendefinisikan input dan output di seluruh basis data, gudang data, dan penyimpanan cloud. Digunakan sebagai cadangan ketika operator tidak memiliki ekstraktor OpenLineage bawaan; mengikuti sistem prioritas empat tingkat di mana ekstraktor kustom dan metode OpenLineage diutamakan. Menyertakan pembantu penamaan dataset untuk Snowflake, BigQuery, S3, dan PostgreSQL guna memastikan konsistensi...

agents/skills/authoring-dags

Panduan kerja untuk membuat DAG Apache Airflow dengan integrasi validasi dan pengujian. Pendekatan enam fase terstruktur: temukan lingkungan dan pola yang ada, rencanakan struktur DAG, implementasikan sesuai praktik terbaik, validasi dengan perintah CLI af, uji dengan persetujuan pengguna, dan lakukan iterasi perbaikan. Perintah CLI untuk penemuan (af config connections, af config providers, af dags list) dan validasi (af dags errors, af dags get, af dags explore) memberikan umpan balik langsung pada 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

Menulis logika tugas Airflow dalam Java, Kotlin, atau bahasa JVM lainnya menggunakan Airflow Java SDK. Gunakan saat pengguna ingin mengimplementasikan tugas Airflow dalam Java/JVM, meminta…

agents/skills/authoring-language-sdk-tasks

Fondasi netral bahasa untuk SDK bahasa Airflow — implementasikan logika tugas dalam bahasa non-Python sementara DAG tetap dalam Python. Gunakan ketika pengguna…

agents/skills/blueprint

Definisikan templat grup tugas Airflow yang dapat digunakan kembali dengan validasi Pydantic dan susun DAG dari YAML. Gunakan saat membuat templat blueprint, menyusun DAG dari…

astronomer/.agents/skills/chart-tests

Gunakan saat menulis, mengedit, meninjau, atau menjalankan pengujian chart Helm untuk repositori Astronomer APC. Mencakup pola pytest, penggunaan render_chart(), sub-chart…

agents/skills/checking-freshness

Verifikasi kesegaran data dengan memeriksa timestamp tabel dan pola pembaruan terhadap skala ketidaksegaran. Mengidentifikasi kolom timestamp menggunakan pola penamaan ETL umum (_loaded_at, _updated_at, created_at, dll.) dan menanyakan nilai maksimumnya untuk menentukan usia. Mengklasifikasikan data ke dalam empat status kesegaran: Segar (< 4 jam), Agak Basi (4–24 jam), Sangat Basi (> 24 jam), atau Tidak Diketahui (tidak ada timestamp ditemukan). Menyediakan template SQL untuk memeriksa waktu pembaruan terakhir dan tren jumlah baris selama beberapa hari terakhir hingga...

astronomer/.agents/skills/circleci

Gunakan saat menulis, mengedit, atau meninjau konfigurasi CircleCI untuk repositori Astronomer APC. Mencakup pengorganisasian skrip, skrip inline vs eksternal, dan…

agents/skills/configuring-airflow-language-sdks

Mengonfigurasi Airflow untuk menjalankan tugas SDK bahasa (Go dan SDK asli di masa depan) — mendaftarkan koordinator, memetakan antrean ke koordinator tersebut, memastikan runtime/artefak pada pekerja,…

agents/skills/cosmos-dbt-core

Konversi proyek dbt Core menjadi DAG atau TaskGroup Airflow menggunakan Astronomer Cosmos. Mendukung tiga pola perakitan: DbtDag mandiri, DbtTaskGroup dalam DAG yang sudah ada, dan operator Cosmos individual untuk kontrol yang lebih terperinci. Pilih dari delapan mode eksekusi (WATCHER, LOCAL, VIRTUALENV, KUBERNETES, AIRFLOW_ASYNC, dan lainnya) berdasarkan kebutuhan isolasi dan kinerja. Menawarkan tiga strategi parsing (dbt_manifest, dbt_ls, dbt_ls_file, otomatis) untuk menyeimbangkan kecepatan dan kompleksitas pemilih...

agents/skills/cosmos-dbt-fusion

Konfigurasikan Astronomer Cosmos untuk proyek dbt Fusion di Snowflake, Databricks, BigQuery, atau Redshift dengan eksekusi lokal. Membutuhkan Cosmos 1.11.0+, biner dbt Fusion yang diinstal secara terpisah di runtime Airflow, dan ExecutionMode.LOCAL dengan pemanggilan subproses. Mendukung tiga strategi penguraian: dbt_manifest (tercepat untuk proyek besar), dbt_ls (untuk pemilih kompleks), atau otomatis (pengaturan sederhana). Mencakup pengaturan ProfileConfig untuk koneksi warehouse, ProjectConfig untuk jalur proyek dbt, dan...

agents/skills/creating-openlineage-extractors

Ekstraktor OpenLineage kustom untuk operator Airflow yang tidak didukung dan skenario lineage yang kompleks. Dua pendekatan: tambahkan metode OpenLineage langsung ke operator yang Anda miliki (direkomendasikan), atau buat ekstraktor kustom untuk operator pihak ketiga yang tidak dapat Anda modifikasi. Ekstraktor mencegat eksekusi operator di tiga titik: sebelum eksekusi untuk lineage statis, setelah sukses untuk output yang ditentukan saat runtime, dan opsional setelah kegagalan untuk lineage parsial. Daftarkan ekstraktor melalui airflow.cfg atau lingkungan...

agents/skills/dag-factory

Buat DAG Apache Airflow secara deklaratif dengan konfigurasi YAML dag-factory. Gunakan saat membuat template dag-factory, menyusun DAG dari YAML untuk dag-factory,…

agents/skills/debugging-dags

Analisis akar penyebab sistematis dan perbaikan untuk DAG Airflow yang gagal dengan alur investigasi terstruktur. Memandu melalui proses diagnosis empat langkah: mengidentifikasi kegagalan, mengekstrak detail kesalahan, mengumpulkan informasi kontekstual, dan memberikan langkah perbaikan yang dapat ditindaklanjuti. Mengkategorikan kegagalan ke dalam empat jenis (data, kode, infrastruktur, ketergantungan) untuk memfokuskan investigasi dan menyarankan perbaikan yang sesuai. Menyediakan perintah CLI siap pakai untuk pengambilan log, perbandingan proses, pembersihan tugas, dan 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

Menyebarkan DAG dan proyek Airflow. Gunakan saat pengguna ingin menyebarkan kode, mendorong DAG, menyiapkan CI/CD, menyebarkan ke produksi, atau bertanya tentang strategi penyebaran…

agents/skills/deploying-go-sdk-bundles

Membangun, mengemas, dan menyebarkan bundel Airflow Go SDK yang telah dikompilasi agar ExecutableCoordinator dapat menjalankannya. Gunakan ketika pengguna ingin mengompilasi bundel tugas Go, meminta…

agents/skills/deploying-java-sdk-bundles

Membangun dan menyebarkan bundle Airflow Java SDK yang telah dikompilasi agar pekerja dapat menjalankannya. Gunakan saat pengguna ingin mengemas bundle tugas JVM ke dalam JAR, bertanya tentang…

agents/skills/discovering-data

Temukan dan jelajahi data untuk suatu konsep atau domain. Gunakan saat pengguna menanyakan data apa yang ada untuk suatu topik (misalnya, "ARR", "pelanggan", "pesanan"), ingin menemukan…