Обратная засыпка воздушного потока DAG - PullRequest
0 голосов
/ 12 октября 2018

Очень простой вопрос - такая сильная головная боль

dag = DAG(
    dag_id='dag_id',
    start_date=datetime(2018, 8, 8),
    schedule_interval=timedelta(minutes=5)
)

BashOperator(
    task_id="xyz",
    bash_command='python3 abc.py',
    dag=dag,
)

Я установил его запуск каждые пять минут, а дата начала - datetime(2018, 8, 8), он начинает заполняться, так как 2018-10-11 20:50

какwaaaat

Моя разница во времени с UTC составляет 4 часа;и он запускает задания после процесса

, поэтому @ ~15:16 сегодня создает журнал с отметкой времени 19:10:53.Я думаю, это хорошо, вроде как, но почему началась засыпка @ 2018-10-11 20:50?

Кроме того, он, похоже, не распознает выражения хрон.Работа вообще не запускается ... например: здесь "15:42", я настроил ее на выполнение @ 19 45 * * *, и ничего не происходит (start_date тоже в прошлом).

Я что-то не так делаю?

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