This release is a pre-release and may not be stable for production use.
awehflow
awehflow is a configuration-driven framework for Apache Airflow that dynamically generates DAGs from simple HOCON or YAML files. It comes with built-in metrics, logging, and alerting to streamline your data orchestration.
Core Concepts
- Configuration-Driven: Define complex DAGs using a clear, hierarchical configuration. No need to write repetitive Python code for each pipeline.
- Dynamic DAG Generation: awehflow automatically constructs and orchestrates Airflow DAGs based on your configurations.
- Built-in Observability: Comes with out-of-the-box event handlers for persisting metrics to a database and alerters for notifications on pipeline status.
- Extensible: Easily add your own custom event handlers and alerters to integrate with any service.
Getting Started
- Getting Started Guide: A step-by-step guide on how to get your first awehflow pipeline up and running.
Configuration Reference
- Configuration Guide: A detailed walkthrough of the configuration system.
Custom Operators and Sensors
awehflow includes a collection of custom operators and sensors to extend Airflow's functionality. While these custom operators provide specialized capabilities, awehflow is fully compatible with all standard Airflow operators. You can use any operator available in your Airflow environment by referencing its fully qualified class name in your configuration.
- Operators Guide: Detailed documentation for all custom operators.
- Sensors Guide: Detailed documentation for all custom sensors.
Command-Line Interface (CLI)
awehflow includes a CLI for generating and validating configurations.
- CLI Documentation: A complete reference for all CLI commands.
Advanced Features
Event Handlers & Alerters
awehflow has a built-in event system that allows you to run custom code in response to pipeline events. Alerters are a special type of event handler designed for sending notifications.
- Alerts Guide: A detailed guide on how to configure and use alerters.
Troubleshooting
- Troubleshooting Guide: Solutions for common issues and debugging tips.
For Developers
Development Environment Setup
To contribute to awehflow, follow these steps to set up a development environment for a specific Airflow version.
- Install Miniconda: Follow the official instructions.
- Create Conda Environment (x86 on Mac ARM): If you are on an ARM-based Mac, create an x86-emulated environment. Add this function to your `.zsh
3 maintainers
Metadata
3 maintainers
Release files for awehflow 5.1.0rc1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| awehflow-5.1.0rc1.tar.gz | 48.1 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| awehflow-5.1.0rc1-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 97.0 kB
Release files / awehflow-5.1.0rc1.tar.gz
| Download URL | awehflow-5.1.0rc1.tar.gz |
|---|---|
| Size | 48.1 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
3685b3e1830c15c095252aa6438d4913a9037bd7b32d4c1f8676b6bf2a7a29c6
|
|
BLAKE2b-256 checksum How to use checksums |
c8c280373ec9410f1cd2fb3e55e1bce85fde665e589c3897d0e2425dd4a63ed9
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.12.21 {"installer":{"name":"uv","version":"0.12.21","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Debian GNU/Linux","version":"13","id":"trixie","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
Release files / awehflow-5.1.0rc1-py3-none-any.whl
| Download URL | awehflow-5.1.0rc1-py3-none-any.whl |
|---|---|
| Size | 48.9 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
d9cbb3b43402efaa975531553246c2158a0ade22b64b331b8f39db96be587272
|
|
BLAKE2b-256 checksum How to use checksums |
63a2fc043712e8d1d7b23693e49c03e41df86df5b888c85aa4001754dfb7cc0e
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.12.21 {"installer":{"name":"uv","version":"0.12.21","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Debian GNU/Linux","version":"13","id":"trixie","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
