def ProductionExporter.export_airflow_dag(self, path=”) [source]
Generate a production-ready Airflow DAG file.
The DAG orchestrates:
- load raw data
- preprocess and score by aidflow package
- push results to warehouse
Parameters
path : Path
Target file path for the generated DAG.
Returns
Path
The written file path.