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

Question

У меня установлена ​​Airflow 1.10.2 с python 3.5.6.

Метаданные лежат в базе данных Mysql с LocalExecutor для исполнения.

Я создал образец helloworld.py dag с графиком ниже.

default_args = {
        'owner': 'Ashish',
        'depends_on_past': False,
        'start_date': datetime(2019, 2, 15),
        'email_on_failure': False,
        'email_on_retry': False,
        'retries': 1,
        'retry_delay': timedelta(minutes=1),
    }

dag = DAG('Helloworld',schedule_interval='56 6 * * *', default_args=default_args)

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

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

Answer 1

Я думаю, вы запутались в start_date:.Ваше текущее расписание должно быть запущено в 6:56 UTC 15.02.2009.С этим графиком DAG будет работать завтра без проблем.Это связано с тем, что Airflow выполняет задания в конце интервала, а не в начале.

start_date: - это не когда вы хотите, чтобы DAG запускался, а когда вы хотите интервал планированияначать.Если вы хотите, чтобы ваша работа выполнялась сегодня, дата начала должна быть: 'start_date': datetime(2019, 2, 14).Тогда ваш текущий ежедневный интервал планирования закончился бы сегодня в 6:56 утра, как задумано, и ваш DAG работал бы.

Взято из этого ответа .