DataHub Airflow Plugin
Automatic lineage and run metadata from Apache Airflow into DataHub — captures DAG structure, task inputs/outputs, and run history with no manual instrumentation.
What you can do
- Capture pipeline lineage — automatically extract dataset-level and column-level lineage from SQL operators
- Track run history — record task execution status, duration, and failures in DataHub
- Enhance OpenLineage — patches Airflow's OpenLineage extractors with DataHub's advanced SQL parser for richer lineage
- Support multiple emitters — send metadata via REST, Kafka, or file
Version compatibility
| Airflow Version | Support |
|---|---|
| 3.0+ | ✅ Fully supported |
| 2.x | ❌ Use acryl-datahub-airflow-plugin <= 1.6.0 |
Installation
pip install acryl-datahub-airflow-plugin
# With Kafka emitter
pip install 'acryl-datahub-airflow-plugin[datahub-kafka]'
Configuration
Add to airflow.cfg:
[datahub]
enabled = True
conn_id = datahub_rest_default # Airflow connection pointing to your DataHub GMS
Set up the Airflow connection:
airflow connections add datahub_rest_default \
--conn-type HTTP \
--conn-host http://localhost:8080
The plugin activates automatically — no changes to your DAG code required.
Key configuration options
| Option | Default | Description |
|---|---|---|
enable_extractors |
True |
Enhance OpenLineage extractors |
patch_sql_parser |
True |
Use DataHub's SQL parser for column-level lineage |
enable_multi_statement_sql_parsing |
False |
Resolve temp tables across multi-statement tasks |
Links
2 maintainers
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file acryl_datahub_airflow_plugin-1.7.0.5.tar.gz.
File metadata
- Download URL: acryl_datahub_airflow_plugin-1.7.0.5.tar.gz
- Upload date:
- Size: 58.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.10.21
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
411ed6809982d3b8bf448f430c7a8b924c26e5cc710b3fb88ddee6e8820fa70a
|
|
| MD5 |
29f1f004496f9aa82a8abcdbd6ffc6ef
|
|
| BLAKE2b-256 |
2fdb322c9b422192c23ff88cc66b4eeecd66c4df605169471213ce5c1b5624ae
|
File details
Details for the file acryl_datahub_airflow_plugin-1.7.0.5-py3-none-any.whl.
File metadata
- Download URL: acryl_datahub_airflow_plugin-1.7.0.5-py3-none-any.whl
- Upload date:
- Size: 75.8 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.10.21
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
f35e6a629d7c95377a8a0a09281ed2f25ed8855f73fba2d107329bcd2d7064ba
|
|
| MD5 |
a030434f2702c96c3a025d436e5a1f6e
|
|
| BLAKE2b-256 |
ce5f76aaf2bb39d4a462eb9ef1d33332fff4b76e4cabd6062af9d995d8a99272
|
