メニュー
Manages Apache Airflow operations including listing, running, and debugging DAGs, viewing logs, and checking server status using the VS Code extension tools.
Codex または Claude でインストール この Prompt をコピーして Codex、Claude、または他のアシスタントに貼り付けると、Skill ページを確認してインストールできます。
SOC 職業分類に基づく
Map downstream lineage and blast radius for Airflow data assets. Use when the user needs to know which DAGs, tables, dashboards, or models depend on a dataset and what could break after a change.
Use when the user needs human-in-the-loop workflows in Airflow (approval/reject, form input, or human-driven branching). Covers ApprovalOperator, HITLOperator, HITLBranchOperator, HITLEntryOperator. Requires Airflow 3.1+.
Annotate Airflow tasks with data lineage using inlets and outlets. Use when the user wants to add lineage metadata to tasks, specify input/output datasets, or enable lineage tracking for operators without built-in OpenLineage extraction.
Workflow and best practices for writing Apache Airflow DAGs. Use when the user wants to create a new DAG, write pipeline code, or asks about DAG patterns and conventions. For testing and debugging DAGs, see the testing-dags skill.
Create custom OpenLineage extractors for Airflow operators. Use when the user needs lineage from unsupported or third-party operators, wants column-level lineage, or needs complex extraction logic beyond what inlets/outlets provide.
Comprehensive DAG failure diagnosis and root cause analysis. Use for complex debugging requests requiring deep investigation like "diagnose and fix the pipeline" or "full root cause analysis".
| name | airflow |
| description | Manages Apache Airflow operations including listing, running, and debugging DAGs, viewing logs, and checking server status using the VS Code extension tools. |
Use the Airflow VS Code extension tools for all Airflow interactions. Avoid shell commands for Airflow operations.
| Tool | Purpose |
|---|---|
list_active_dags | List active (unpaused) DAGs |
list_paused_dags | List paused DAGs |
get_running_dags | Show running or queued DAG runs |
pause_dag | Pause a DAG |
unpause_dag | Unpause a DAG |
trigger_dag_run | Trigger a DAG run |
get_dag_runs | List DAG runs for a DAG |
get_dag_history | Daily run history for a DAG |
get_failed_runs | Failed runs across DAGs |
analyse_dag_latest_run | Full analysis of latest run (tasks, logs, source) |
get_dag_run_detail | Full analysis of a specific run |
get_dag_source_code | Retrieve DAG source code |
go_to_dag_view | Open DAG view panel |
go_to_dag_log_view | Open log view panel |
go_to_connections_view | Open connections panel |
go_to_variables_view | Open variables panel |
go_to_providers_view | Open providers panel |
go_to_configs_view | Open configs panel |
go_to_plugins_view | Open plugins panel |
go_to_server_health_view | Open server health panel |
list_active_dags and list_paused_dagsget_dag_source_codepause_dagunpause_dagtrigger_dag_runget_dag_runsanalyse_dag_latest_run or get_dag_run_detailgo_to_dag_log_view or analyse_dag_latest_runanalyse_dag_latest_rungo_to_connections_viewgo_to_variables_viewgo_to_server_health_viewget_failed_runsanalyse_dag_latest_runget_dag_run_detailgo_to_dag_log_viewtrigger_dag_runget_dag_runsanalyse_dag_latest_rungo_to_server_health_viewget_running_dagsget_failed_runs