Как я могу проверить, запланирован ли мой следующий запуск Airflow DAG для определенного dag?

Question

У меня настроен и запущен поток воздуха с некоторыми группами доступности баз данных, запланированными на один раз в день "0 0 * * *".

Я хочу проверить, когда в следующий раз запланирован запуск определенного дамба, но я не вижу, где я могу это сделать в админке.

Answer 1

Рассчитать, используя Расписание и Последний запуск в пользовательском интерфейсе веб-сервера воздушного потока.

Кроме того, вы можете попробовать эту конечную точку

curl http://localhost:8000/api/experimental/latest_runs

Это дает вам результат как

{
  "items": [
    {
      "dag_id": "evaluate_discount_strategy",
      "dag_run_url": "/admin/airflow/graph?dag_id=evaluate_discount_strategy&execution_date=2019-05-06+15%3A17%3A56.641027%2B00%3A00",
      "execution_date": "2019-05-06T15:17:56.641027+00:00",
      "start_date": "2019-05-06T15:17:56.655972+00:00"
    },
    {
      "dag_id": "target_steering",
      "dag_run_url": "/admin/airflow/graph?dag_id=target_steering&execution_date=2019-05-17+09%3A36%3A21.644039%2B00%3A00",
      "execution_date": "2019-05-17T09:36:21.644039+00:00",
      "start_date": "2019-05-17T09:36:21.659580+00:00"
    }
  ]
}

затем добавьте schedule время к start_date, чтобы получить следующие запуски.

Этот API-интерфейс также можно использовать для получения дат выполнения между заданными временами.

    def get_run_dates(self, start_date, end_date=None):
        """
        Returns a list of dates between the interval received as parameter using this
        dag's schedule interval. Returned dates can be used for execution dates.

        :param start_date: the start date of the interval
        :type start_date: datetime
        :param end_date: the end date of the interval, defaults to timezone.utcnow()
        :type end_date: datetime
        :return: a list of dates within the interval following the dag's schedule
        :rtype: list
        """    

Официальная ссылка на документацию

Answer 2

Если вы хотите использовать Airflow CLI, есть опция next_execution

Получить дату и время следующего выполнения группы DAG.

airflow next_execution [-h] [-sd SUBDIR] dag_id

Answer 3

Если вы хотите получить это в потоке воздуха, вы можете использовать jinja {{ next_execution_date }}, но если вы просто хотите узнать, когда будет запущен ваш даг, вы можете добавить интервал с последним запуском

Например

с рисунка ниже

Интервал расписания составляет 15 минут, а последний запуск был в 2018-09-07 08:32, поэтому следующий запуск будет ровно через 15 минут, а это 2018-09-07 08: 47