Принудительный запуск задачи, пропущенной ShortCircuitOperator

Question

У меня есть DAG, которая использует ShortCircuitOperator для пропуска последующих задач, которые (как правило) не нужны. В некоторых исключительных обстоятельствах я хотел бы по-прежнему выполнять эти последующие задачи и предпочел бы не вносить изменения в мою группу обеспечения доступности баз данных для решения каждого возможного случая. Есть ли простой способ в пользовательском интерфейсе Airflow или через консоль принудительно запускать последующие задачи после их пропуска?

Answer 1

Отвечая на мой собственный вопрос здесь, вы можете вручную очистить состояние экземпляров задач через пользовательский интерфейс, но вы должны очистить состояние последующих задач. У меня возникли проблемы, потому что я хотел пропустить часть DAG и пытался прояснить состояние задач в дальнейшем, что, конечно, заставляло их сразу же переходить к повторному пропуску. Если вы действительно хотите пропустить часть DAG таким образом, вы можете это сделать, вам просто нужно вручную установить зависимости сразу перед задачами, которые вы хотите выполнить успешно.