Я борюсь со странной проблемой, которую не могу понять. У меня есть базовая DAG, которая не делает ничего особенного. Он просто использует оператор bash для запуска скрипта Python.
У меня запланирован запуск этой DAG каждый понедельник. Когда я включаю даг на веб-сервере, он начинает заполняться до 25 сентября. Однако засыпки на 2-е октября не происходит. Когда я меняю расписание с еженедельного на ежедневное, все работает нормально.
Это моя установка DAG.
default_args = {
'owner': 'xxxxx',
'depends_on_past': False,
'email': ['xxxxxx'],
'start_date': datetime(2017, 9, 1, 0, 0),
'email_on_failure': False,
'email_on_retry': False,
'retries': 2,
'retry_delay': timedelta(minutes=10),
}
# Create DAG
dag = DAG(dag_id='IFS_weekly_forecast',
schedule_interval = '0 8 * * MON',
default_args=default_args)
Как видно из этой картинки, обратная засыпка идет нормально до 25 числа. После этого в очереди нет новых задач.
Что я здесь делаю неправильно? У меня есть другие DAG, которые работают нормально в течение нескольких недель. Я также перезапустил планировщик и веб-сервер, это не помогло.
Редактировать:
Тема ниже, кажется, охватывает ту же проблему. Однако это меняет мой вопрос. Как я могу позволить воздушному потоку запускаться еженедельно в указанную дату, вместо того, чтобы ждать окончания всего этого периода?
