Планировщик задач воздушного потока - PullRequest
Новая
       10

Планировщик задач воздушного потока

0 голосов
/ 21 апреля 2019

Мое требование состоит в том, чтобы планировать выполнение задачи dag с каждого воскресенья с 21:00 до 21:00 пятницы на каждые 5 минут. Может ли кто-нибудь помочь мне, как мне этого добиться. 

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2019,4,13,21,0),
    'email': [],
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1,
    # 'retry_delay': timedelta(minutes=5),
    # 'queue': 'bash_queue',
    # 'pool': 'backfill',
    # 'priority_weight': 10,
    # 'end_date': datetime(2016, 1, 1),
}


dag = DAG(
    'EUR_USD', catchup=False, default_args=default_args )

    # Define the task that prints hello with the bash operator.
    t1 = BashOperator(
    task_id='FxScheduler',
    schedule_interval="*/5 * * * 1-5",
    bash_command='sh Hello.sh ',
    dag=dag
)

Я использовал вышеуказанный код, Как я могу упомянуть, что это задание должно прекратиться в пятницу, 9 часов вечера, и снова должно начаться в воскресенье, 9 часов вечера?.

Ответы [ 2 ]

0 голосов
/ 22 апреля 2019

Этот сайт действительно полезен, https://crontab.guru/ Может быть, вы можете получить идею для этого?* / 5 21 * * 5,6,0

0 голосов
/ 22 апреля 2019

Я думаю, что вы можете сослаться на эту вики-страницу .

Расписание должно быть "* / 5 * * * 0-5".

...