Astronomerスキル

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

AIPとPR実装から検証済みのレシピプレイブックを生成（ポストモード）、または実装のないAIPから推測ユーザーストーリーを生成（プレモード）。使用…

agents/skills/airflow

Apache AirflowのDAG、実行、タスク、システム設定をクエリ、管理、トラブルシューティングします。DAG検査、実行管理、タスクログ、設定クエリ、REST API直接アクセスを含む30以上のコマンドをサポート。複数のAirflowインスタンスを永続的な設定で管理し、ローカルおよびAstroデプロイメントを自動検出。DAG実行を同期的（完了待機）または非同期的にトリガーし、障害を診断、再試行のために実行をクリア、リトライ/マップインデックスフィルタリング付きでタスクログにアクセス。出力...

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

Airflowアダプターパターン（v2/v3 API互換用）。アダプター、バージョン検出、または複数バージョンで動作する新しいAPIメソッドの追加時に使用します。

agents/skills/airflow-hitl

人間による承認ゲート、フォーム入力、およびAirflow DAG内での分岐を、遅延可能オペレーターを使用して実現。4種類のオペレーター：承認/却下の判断を行うApprovalOperator、フォームによる複数選択肢の選択を行うHITLOperator、人間主導のタスクルーティングを行うHITLBranchOperator、フォームデータ収集を行うHITLEntryOperator。すべてのオペレーターは遅延可能であり、Airflow UIのRequired Actionsタブまたは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

Airflow向けの新しい言語SDK（AIP-108）を実装するためのガイド。新しいプログラミング言語のサポートを追加したいコントリビューター向けのスキルです。

agents/skills/airflow-plugins

Airflow 3.1+のプラグインを構築し、FastAPIアプリ、カスタムUIページ、Reactコンポーネント、ミドルウェア、マクロ、オペレーターリンクをAirflow UIに直接埋め込みます。使用…

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 UIの翻訳を追加または更新します。ロケールの設定、翻訳ファイルのスキャフォールディング、ロケール固有の翻訳をガイドします…

agents/skills/analyzing-data

データウェアハウスにクエリを実行し、キャッシュされたパターンと概念マッピングを使用してビジネス上の質問に回答します。繰り返し発生する質問タイプのパターン検索とキャッシュをサポートし、結果を記録して将来のクエリを改善します。概念からテーブルへのマッピングキャッシュと、INFORMATION_SCHEMAまたはコードベースのgrepによるテーブルスキーマ検出を含みます。分析用にPolarsまたはPandas DataFrameを返すrun_sql()およびrun_sql_pandas()カーネル関数を提供します。概念、パターン、テーブルキャッシュを管理するCLIコマンド、さらに...

agents/skills/annotating-task-lineage

Airflowタスクにデータ系列を注釈付けし、インレットとアウトレットを使用します。OpenLineage Datasetオブジェクト、Airflow Assets、Airflow Datasetsをサポートし、データベース、データウェアハウス、クラウドストレージ間での入出力を定義します。オペレーターに組み込みのOpenLineage抽出機能がない場合のフォールバックとして使用し、カスタム抽出機能とOpenLineageメソッドが優先される4段階の優先順位システムに従います。Snowflake、BigQuery、S3、PostgreSQL向けのデータセット命名ヘルパーを含み、一貫性を確保します。

agents/skills/authoring-dags

Apache Airflow DAGを作成するためのガイド付きワークフローで、検証とテストの統合を備えています。構造化された6フェーズのアプローチ：環境と既存のパターンを発見し、DAG構造を計画し、ベストプラクティスに従って実装し、af CLIコマンドで検証し、ユーザーの同意を得てテストし、修正を繰り返します。発見用のCLIコマンド（af config connections、af config providers、af dags list）と検証用のCLIコマンド（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を使用して記述します。ユーザーがJava/JVMでAirflowタスクを実装したい場合、または…と尋ねた場合に使用します。

agents/skills/authoring-language-sdk-tasks

Airflow言語SDKの言語に依存しない基盤 — DAGはPythonのまま、タスクロジックをPython以外の言語で実装。ユーザーが…場合に使用。

agents/skills/blueprint

Pydanticバリデーションを使用して再利用可能なAirflowタスクグループテンプレートを定義し、YAMLからDAGを構成します。ブループリントテンプレートの作成時や、DAGの構成時に使用します。

astronomer/.agents/skills/chart-tests

Astronomer APCリポジトリのHelmチャートテストを作成、編集、レビュー、実行する際に使用します。pytestパターン、render_chart()の使用法、サブチャート…をカバーします。

agents/skills/checking-freshness

テーブルのタイムスタンプと更新パターンを陳腐化スケールに照らして確認し、データの鮮度を検証します。一般的なETL命名パターン（_loaded_at、_updated_at、created_atなど）を使用してタイムスタンプカラムを特定し、その最大値をクエリして経過時間を判定します。データを4つの鮮度ステータスに分類します：Fresh（4時間未満）、Stale（4～24時間）、Very Stale（24時間超）、またはUnknown（タイムスタンプなし）。最近の日数における最終更新時刻と行数トレンドを確認するためのSQLテンプレートを提供します...

astronomer/.agents/skills/circleci

Astronomer APCリポジトリのCircleCI設定を作成、編集、またはレビューする際に使用します。スクリプトの構成、インラインスクリプトと外部スクリプトの比較などに対応します。

agents/skills/configuring-airflow-language-sdks

Airflowを設定して、言語SDKタスク（Goおよび将来のネイティブSDK）を実行できるようにします — コーディネーターを登録し、キューをマッピングし、ワーカー上でランタイム/アーティファクトを確保します…

agents/skills/cosmos-dbt-core

Astronomer Cosmosを使用して、dbt CoreプロジェクトをAirflow DAGまたはTaskGroupに変換します。3つのアセンブリパターン（スタンドアロンのDbtDag、既存のDAG内のDbtTaskGroup、細かい制御が可能な個別のCosmosオペレーター）をサポートします。分離とパフォーマンスのニーズに基づいて、8つの実行モード（WATCHER、LOCAL、VIRTUALENV、KUBERNETES、AIRFLOW_ASYNCなど）から選択できます。速度とセレクターの複雑さのバランスを取るために、3つの解析戦略（dbt_manifest、dbt_ls、dbt_ls_file、automatic）を提供します...

agents/skills/cosmos-dbt-fusion

Astronomer CosmosをSnowflake、Databricks、BigQuery、Redshift上のdbt Fusionプロジェクト向けにローカル実行で設定します。Cosmos 1.11.0以上、Airflowランタイムに別途インストールされたdbt Fusionバイナリ、およびサブプロセス呼び出しによるExecutionMode.LOCALが必要です。3つの解析戦略をサポート：dbt_manifest（大規模プロジェクトに最速）、dbt_ls（複雑なセレクター向け）、またはautomatic（シンプルな設定）。ウェアハウス接続用のProfileConfig、dbtプロジェクトパス用のProjectConfigの設定などをカバーします。

agents/skills/creating-openlineage-extractors

カスタムOpenLineage抽出器。未対応のAirflowオペレーターや複雑な系列シナリオ向け。2つのアプローチ：所有するオペレーターに直接OpenLineageメソッドを追加する方法（推奨）、または変更できないサードパーティ製オペレーター用にカスタム抽出器を作成する方法。抽出器は3つの時点でオペレーターの実行をインターセプトします：静的な系列のための実行前、実行時に決定される出力のための成功後、およびオプションで部分的な系列のための失敗後。抽出器はairflow.cfgまたは環境変数経由で登録...

agents/skills/dag-factory

Apache Airflow DAGをdag-factoryのYAML設定で宣言的に作成します。dag-factoryテンプレートの作成時、dag-factory用のYAMLからDAGを構成する際などに使用します。

agents/skills/debugging-dags

失敗したAirflow DAGに対する体系的な根本原因分析と修正、構造化された調査ワークフローを提供。4段階の診断プロセス（障害の特定、エラー詳細の抽出、コンテキスト情報の収集、実行可能な修正手順の提示）をガイド。障害を4つのタイプ（データ、コード、インフラストラクチャ、依存関係）に分類し、調査を集中させ適切な修正を提案。ログ取得、実行比較、タスククリア、DAG...のための即時使用可能なCLIコマンドを提供。

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

AirflowのDAGやプロジェクトをデプロイします。ユーザーがコードのデプロイ、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」「顧客」「注文」）に関するデータの存在を尋ねたり、見つけたい場合に使用します。