Quelqu'un peut-il m'expliquer en termes simples ce qu'est un graphe acyclique dirigé? J'ai regardé sur Wikipédia mais cela ne me fait pas vraiment voir son utilisation en
J'essaie de déplacer des fichiers s3 d'un compartiment "sans suppression" (ce qui signifie que je ne peux pas supprimer les fichiers) vers GCS en utilisant airflow. Je ne peux pas garantir que de nouveaux fichiers seront présents tous les jours, mais je dois vérifier chaque jour de nouveaux...
J'ai un scénario comme ci-dessous: Déclenchez a Task 1et Task 2uniquement lorsque de nouvelles données sont disponibles pour eux dans la table source (Athena). Le déclenchement de Task1 et Task2 devrait se produire lors d'une nouvelle partition de données dans une journée. Déclencher Task...