Tracing Downstream Lineage

Warehouse Init

astronomer

Discovers data warehouse schema metadata and generates a shareable .astro/warehouse.md reference file for fast concept-to-table lookups.

Tracing Upstream Lineage

astronomer

Trace upstream data lineage. Use when the user asks where data comes from, what feeds a table, upstream dependencies, data sources, or needs to understand data origins.

Testing Dags

astronomer

Guides iterative testing, debugging and fixing of Airflow DAGs using af CLI commands.

Setting Up Astro Project

astronomer

Initializes and configures Astro/Airflow projects with the Astro CLI, covering dependencies, connections, and variables.

Profiling Tables

astronomer

Profiles a database table with SQL statistics, cardinality, samples and a data quality assessment.

Managing Astro Local Env

astronomer

Manage a local Airflow environment with the Astro CLI: start, stop, restart, logs, API queries and troubleshooting.

Creating Openlineage Extractors

astronomer

Guides creation of custom OpenLineage extractors for Airflow operators lacking built-in lineage support.

Checking Freshness

astronomer

Checks whether database tables are fresh by querying timestamp columns and reporting staleness status.

Blueprint

astronomer

Guides building reusable Airflow DAG templates with Pydantic validation and composing DAGs from YAML.

Annotating Task Lineage

astronomer

Guides adding manual data lineage annotations to Airflow tasks using inlets and outlets.

Weekly Brief

amplitude

Produces a weekly Amplitude analytics briefing covering trends, wins, risks, and next-week priorities.

User Cohort Forensics

amplitude

Investigates individual users and user populations in Amplitude, resolving identities, reading profiles and analyzing event timelines.