Datenverfügbarkeit mit einem Asset-Outlet signalisieren

Dein Team hat eine Pipeline, die tägliche Verkaufsdaten nach s3://data-lake/sales/daily.csv schreibt, und mehrere nachgelagerte Pipelines hängen davon ab. Anstatt sie per Timer pollen zu lassen oder raten zu müssen, wann die Datei fertig ist, hängst du ein Asset-Outlet an, damit diese Aufgabe sofort beim Abschluss signalisiert, dass die Daten aktualisiert wurden. Dieses Signal ermöglicht es anderen Dags, sich direkt auf Basis der Daten zu planen.

Führe nach dem Vervollständigen des Codes die Datei aus und prüfe anschließend mit der Airflow-CLI, ob das Asset registriert und aktualisiert wurde.