tracing-upstream-lineage
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.
Install
git clone https://github.com/astronomer/agents /tmp/agents && ln -s /tmp/agents/skills/tracing-upstream-lineage ~/.claude/skills/tracing-upstream-lineage
From README
Upstream Lineage: Sources Trace the origins of data - answer "Where does this data come from?" Lineage Investigation Step 1: Identify the Target Type Determine what we're tracing: Table: Trace what populates this table Column: Trace where this specific column comes from DAG: Trace what data sources this DAG reads from Step 2: Find the Producing DAG Tables are typically populated by Airflow DAGs. Find the connection: Search DAGs by name: Use af dags list and look for DAG names matching the table name loadcustomers -> customers table etldailyorders -> orders table Explore DAG source code: Use af dags source to read the DAG definition Look for INSERT, MERGE, CREATE TABLE statements Find the target table in the code Check DAG tasks: Use af tasks list to see what operations the DAG performs On Astro If you're running on Astro, the Lineage tab in the Astro UI provides visual lineage exploration across DAGs and datasets.
More from this repo
airflow-state-store
Persists task and asset state across retries and DAG runs using Airflow 3.3's AIP-103 key/value stores...
authoring-go-sdk-tasks
Writes Airflow task logic in Go using the Airflow Go SDK.
authoring-java-sdk-tasks
Writes Airflow task logic in Java, Kotlin, or any JVM language using the Airflow Java SDK.
