Воздушный поток - укажите время суток для параметра времени ожидания выполнения

Question

Мой DAG планируется запускать ежедневно в 7 часов утра. Могу ли я указать время суток для параметра времени ожидания выполнения вместо продолжительности.

Например, я хочу добавить указанное c время 12:00, чтобы задание не выполнялось, если оно все еще выполняется в 12:00.

Answer 1

Такой параметр отсутствует в BaseOperator или DAG

---

У вас будет его сборка. Вот некоторый намек, как вы можете go об этом (не уверен, что это сработает)

• Написать пользовательский TimeSensor (не путать с TimeDeltaSensor) путем подкласса этого убивает DAG при неудаче.
  • Вам придется переопределить метод execute()
  • Для убийства вы можете посмотреть _mark_dagrun_state_as_failed() метод
• С указанным тайм-аутом datetime добавьте эту пользовательскую задачу датчика в качестве одной из начальных задач (задачи, у которых нет восходящей задачи) из вас DAG

---

В случае, если вам нужно тайм-аут некоторых определенных c задач (ы) вместо всего DAG

• , вы можете изменить запись другого пользовательского датчика времени, который отмечает спецификацию c задача не выполнена по истечении времени ожидания.
  • Вы можете использовать _mark_task_instance_state() метод для него
• Вы можете подключить этот пользовательский датчик времени с этой задачей в параллельно (чтобы задача и датчик запускались вместе)