Machine Learning Orchestration
dbnd-airflow-auto-tracking
is a plugin for Airflow, enabling dbnd tracking to all DAGs and tasks without any code changes.
The plugin will go over tasks and modify them if needed. It uses Airflow's policy mechanism by adding dbnd tracking to policy function. If the user had already defined its own policy function it will be executed in addition to dbnd tracking.
pip install dbnd-airflow-auto-tracking