Skip to main content

Configuration based Apache Airflow

Project description

awehflow

coverage report pipeline status

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

Configuration Reference

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.

Command-Line Interface (CLI)

awehflow includes a CLI for generating and validating configurations.

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

For Developers

Development Environment Setup

To contribute to awehflow, follow these steps to set up a development environment for a specific Airflow version.

  1. Install Miniconda: Follow the official instructions.
  2. 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

Project details


Release history Release notifications | RSS feed

This version

4.0.7

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

awehflow-4.0.7.tar.gz (40.2 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

awehflow-4.0.7-py3-none-any.whl (43.6 kB view details)

Uploaded Python 3

File details

Details for the file awehflow-4.0.7.tar.gz.

File metadata

  • Download URL: awehflow-4.0.7.tar.gz
  • Upload date:
  • Size: 40.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.3

File hashes

Hashes for awehflow-4.0.7.tar.gz
Algorithm Hash digest
SHA256 c18ccbfe28f0910ced6a2880dfc3dda620699946cc4594376bfec098d1ffcadc
MD5 981f0f9f111a74a942bc36a71c9ed9bd
BLAKE2b-256 83329f059a25e46117b647d043a9d8799df2c09f9597fab606784463bf0a0458

See more details on using hashes here.

File details

Details for the file awehflow-4.0.7-py3-none-any.whl.

File metadata

  • Download URL: awehflow-4.0.7-py3-none-any.whl
  • Upload date:
  • Size: 43.6 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.3

File hashes

Hashes for awehflow-4.0.7-py3-none-any.whl
Algorithm Hash digest
SHA256 c7c2bcfa2655138e81e9b0bac2d39ffa077f021def6eaa5d39f32b0f15edc4a4
MD5 72ab4e7e363f566557274fd21da3aee4
BLAKE2b-256 bf902ca5ad1734aa6315678d485bfe8487c15f0df94754276d677583de46468b

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page