etlantic-airflow
Airflow reference orchestrator compiler for ETLantic 0.20.
pip install 'etlantic==0.31.0' 'etlantic-airflow==0.31.0'
# or: pip install 'etlantic[airflow]'
# To import generated DAGs into an Airflow process, install apache-airflow
# separately in the Airflow environment (not required for compile).
Wiring
from etlantic import Profile, plan_pipeline, compile_plan
profile = Profile(
name="airflow-prod",
orchestrator="airflow",
schedule={"type": "cron", "expression": "0 2 * * *", "timezone": "UTC"},
execution={"retries": 2, "timeout_seconds": 3600},
)
plan = plan_pipeline(MyPipeline, profile=profile)
artifact = compile_plan(plan, target="airflow", profile=profile)
artifact.write("dags/my_pipeline.py")
The etlantic.orchestrator_plugins entry point named airflow registers
etlantic_airflow:create_plugin. Set orchestrator="airflow" in the profile,
validate and plan first, then compile the valid plan with
etlantic compile TARGET --target airflow -o dags/.
Capabilities
- Deterministic Airflow DAG module generation from a secret-free
PipelinePlan - Schedule, retry, timeout, and dependency mapping
- Retry-safety fail-closed for unsafe sinks
- Artifact-ref-only XCom payloads (no large inline data)
- Lifecycle correlation keys for normalized run reports
Not included: managed Airflow deployments, Dagster compile plugins, or
Prefect (shipped separately as an ExecutionScheduler local MVP, not as an
Airflow-style compiler).
1 maintainer
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 etlantic_airflow-0.31.0.tar.gz.
File metadata
- Download URL: etlantic_airflow-0.31.0.tar.gz
- Upload date:
- Size: 5.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.3 {"installer":{"name":"uv","version":"0.11.3","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
973abc794e39f740896132e1a42f5d3df9ac540feb7e7d24b96dd5a97a1bdad4
|
|
| MD5 |
e10881fdaa406833ae11915c96f88b6f
|
|
| BLAKE2b-256 |
60922fb0b0d799af9b2b9558f69bd77676d46a3706dd041ea237bba3a6e71bd5
|
File details
Details for the file etlantic_airflow-0.31.0-py3-none-any.whl.
File metadata
- Download URL: etlantic_airflow-0.31.0-py3-none-any.whl
- Upload date:
- Size: 7.8 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.3 {"installer":{"name":"uv","version":"0.11.3","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
41d4f24fba6d96dd046895e5dd69f842083206165c9329df4be730f53a4fbb2a
|
|
| MD5 |
912252658a36081aca934e127ebfa795
|
|
| BLAKE2b-256 |
aec62787d9f24d01e39cddc601b2ed5f5d8c5991018fef1805d31cd9da0f839e
|
