Je cours le pipeline de flux d'air mais les codes semble bons mais en fait j'obtiens l'airflow.exceptions.AirflowException: Cycle détecté dans DAG. Tâche défectueuse: pouvez-vous s'il vous plaît aider à résoudre ce problèmeairflow.exceptions.AirflowException: Cycle détecté dans DAG. Tâche défectueuse
0
A
Répondre
0
Sans le code, il est difficile de vous aider. Cependant, cela signifie que vous avez une boucle dans votre DAG. Généralement, cette erreur se produit lorsque l'une de vos tâches a une tâche en aval dont la propre chaîne aval l'inclut à nouveau (A appelle B appelle C appelle D à nouveau, par exemple). Cela n'est pas autorisé par Airflow (et les DAG en général).
0
La canalisation de flux d'air est basée sur des DAG (Dirigé Acyclic) ce qui signifie qu'il n'y a pas de boucles ou de cycles dans le pipeline.
Organisez votre pipeline de manière à ce qu'il n'y ait pas de cycles. Une tâche en aval ne devrait appeler aucune de ses propres tâches en amont.