2017-08-17 1 views

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.