Astronomer

Skills

34 in the Claude listing

• airflowQueries, manages, and troubleshoots Apache Airflow using the `af` CLI.
• Airflow hitlBuilds human-in-the-loop (HITL) Airflow workflows - approval gates, form input, and human-driven branching.
• Airflow pluginsBuilds Airflow 3.1+ plugins that embed FastAPI apps, custom UI pages, React components, middleware, macros, and operator links directly into the Airflow UI.
• Airflow state storePersists 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 crash-safe `ResumableJobMixin`.
• Analyzing dataQueries the data warehouse with SQL and answers business questions about data.
• Annotating task lineageAnnotate Airflow tasks with data lineage using inlets and outlets.
• Authoring dagsWorkflow and best practices for writing Apache Airflow DAGs.
• Authoring go sdk tasksWrites Airflow task logic in Go using the Airflow Go SDK.
• Authoring java sdk tasksWrites Airflow task logic in Java, Kotlin, or any JVM language using the Airflow Java SDK.
• Authoring language sdk tasksThe language-neutral foundation for Airflow language SDKs — implement task logic in a non-Python language while the DAG stays in Python.
• blueprintDefine reusable Airflow task group templates with Pydantic validation and compose DAGs from YAML.
• Checking freshnessQuick data freshness check.
• Configuring airflow language sdksConfigures Airflow to run language SDK tasks (Java, Go, and future native SDKs) — register a coordinator, map a queue to it, ensure the runtime/artifact on workers, and tune coordinator options.
• Cosmos dbt coreTurns a dbt Core project into an Airflow DAG/TaskGroup using Astronomer Cosmos.
• Cosmos dbt fusionRun a dbt Fusion project with Astronomer Cosmos.
• Creating openlineage extractorsCreate custom OpenLineage extractors for Airflow operators.
• Dag factoryAuthors Apache Airflow DAGs declaratively from dag-factory YAML configs.
• Debugging dagsComprehensive DAG failure diagnosis and root-cause analysis with structured investigation and prevention recommendations.
• Delegating to ottoDrives Astronomer's Otto agent (`astro otto`) as a delegated sub-agent for Airflow, dbt, and data-engineering work.
• Deploying airflowDeploys Airflow DAGs and projects.
• Deploying go sdk bundlesBuilds, packs, and deploys compiled Airflow Go SDK bundles so the ExecutableCoordinator can run them.
• Deploying java sdk bundlesBuilds and deploys compiled Airflow Java SDK bundles so workers can run them.
• Managing astro deploymentsManage Astronomer production deployments with Astro CLI.
• Managing astro local envManage local Airflow environment with Astro CLI (Docker and standalone modes).
• Migrating ai sdk to common aiMigrates Airflow projects from airflow-ai-sdk to apache-airflow-providers-common-ai 0.4.0+.
• Migrating airflow 2 to 3Guide for migrating Apache Airflow 2.x projects to Airflow 3.x.
• Migrating dagster to airflowGuide for migrating Dagster projects to Apache Airflow 3 on Astro.
• Profiling tablesDeep-dive data profiling for a specific table.
• Setting up astro projectInitialize and configure Astro/Airflow projects.
• Testing dagsComplex DAG testing workflows with debugging and fixing cycles.
• Tracing downstream lineageTrace downstream data lineage and impact analysis.
• Tracing upstream lineageTrace upstream data lineage.
• Troubleshooting astro deploymentsTroubleshoot Astronomer production deployments with Astro CLI.
• Warehouse initInitialize warehouse schema discovery.