气流 - 指定一天中执行超时参数的时间。

Question

我的DAG被安排在每天早上7点运行。我是否可以指定一天中的时间为执行超时参数，而不是持续时间。

例如，我想添加特定的时间为晚上12点，这样，如果作业在晚上12点还在运行，就会失败。

Answer 1

这样的参数不存在于 BaseOperator 或 DAG

---

你会有一个建立它。这里有一些提示，你可以如何去做（不知道这是否会成功）。

• 写一个自定义的 TimeSensor (别忘了 TimeDeltaSensor)进行子类化，失败后会杀死DAG。
  • 你必须覆盖 execute() 办法
  • 杀人的事你可以看看 _mark_dagrun_state_as_failed() 办法
• 与指定的 datetime 超时，将该自定义传感器任务添加为其中一个 开工 你的 DAG

---

如果您需要超时一些特定的任务，而不是整个DAG。

• 您可以更改编写另一个自定义的时间传感器，在超时时将特定任务标记为失败。
  • 您可以使用 _mark_task_instance_state() 办法 为它
• 你可以在下面的任务中为这个自定义的时间传感器布线。平行 (使任务和它的传感器一起启动)