Een productie-pijplijn maken #1

Je hebt veel geleerd over hoe Airflow werkt — nu is het tijd om je workflow te implementeren in een productie-pijplijn met allerlei objecten, waaronder sensors en operators. Je baas wil graag dat deze workflow geautomatiseerd wordt en SLA-rapportage kan leveren, omdat dat extra gewicht in de schaal legt om een deal te sluiten waar het salesteam aan werkt. De salesprospect heeft aangegeven dat ze willen tekenen voor de aangegeven dataservice zodra ze geautomatiseerde updates zien.

Van wat je over het proces hebt geleerd, weet je dat er salesdata wordt geüpload naar het systeem. Zodra de data is geüpload, moet er een nieuw bestand worden aangemaakt om de volledige verwerking te starten, maar er gaat iets niet goed.

Bekijk de broncode van de DAG om te bepalen of er nog iets extra’s moet worden toegevoegd.