Как получить время окончания предыдущей работы

Question

У меня есть задание, которое назначается каждые несколько минут.

Я хочу реализовать логику, когда новая задача начинается там, где прервана предыдущая успешно выполненная задача.

Конкретнее, я использую эти временные интервалы для запросов к базе данных, поэтому я не пропускаю некоторые данные между выполнениями.

Как этого можно достичь?

Answer 1

Посмотрите документацию по макросам. Вы можете видеть, что у вас есть две переменные, которые вы можете использовать в своих файлах sql: {{ execution_date }} а также {{ next_execution_date }} - вы должны использовать их для запроса базы данных для временного интервала, например, такого:

select * 
from 
  table
where
  timestamp_column >= {{ execution_date }} 
  and timestamp_column < {{ next_execution_date }}