Signaler la disponibilité des données avec une sortie d'Asset

Votre équipe dispose d'un pipeline qui écrit les ventes quotidiennes dans s3://data-lake/sales/daily.csv, et plusieurs pipelines en aval en dépendent. Plutôt que de les faire interroger périodiquement ou deviner quand le fichier est prêt, vous allez ajouter une sortie d'Asset afin que cette tâche signale que les données ont été mises à jour dès qu'elle se termine. Ce signal permet aux autres Dags de se programmer directement à partir des données.

Après avoir complété le code, exécutez le fichier, puis vérifiez que l'asset a été enregistré et mis à jour à l'aide de l'interface en ligne de commande d'Airflow (CLI).