flowetl

Source: flowetl/__init__.py

The FlowETL module augments AirFlow with several special purpose operators and sensors, default qa checks, and a utility function for easily creating ETL DAGs for CDR data. FlowETL is built into the FlowETL docker container, but can also be installed independently.