Я играл с SubDAG. Большой проблемой, с которой я столкнулся, является то, что всякий раз, когда что-то в SubDAG выходит из строя, и я повторно запускаю что-то, нажимая Clear, повторно запускается только очищенная задача; успех не распространяется на последующие задачи в SubDAG и не запускает их.
Как мне повторно запустить невыполненную задачу в SubDAG, чтобы последующие задачи выполнялись правильно? Прямо сейчас я должен буквально повторно запускать каждую задачу в SubDAG, которая находится ниже по течению после сбойной задачи.
Думаю, я следовал лучшим практикам SubDAG; SubDAG наследует свойства Parent DAG везде, где это возможно (включая schedule_interval
), и я не включаю SubDAG в пользовательском интерфейсе; родительский DAG включен и вместо этого запускает его.