1

我需要在周一至周四晚上 7 点安排工作,周五我需要在晚上 11 点安排工作。我正在使用 Airflow 并且需要 cron 制表符,例如

0 19 * * 周一至周四

欢迎任何建议。

谢谢

问候, CJ

4

2 回答 2

0

您可以将 dag 创建为:

dag = DAG("Your_dag", default_args=default_args, schedule_interval="0 19 * * 1-4")
于 2017-05-30T10:25:51.257 回答
0

你可以这样做:

schedules = {
    'M-Th': '0 19 * * 1-4',
    'F': '0 23 * * 5',
}

for name, schedule in schedules.items():
    globals()[name] = DAG('<base_dag_name.' + name, default_args=default_args, schedule_interval=schedule)

这将从单个文件创建两个 DAG。DAG 需要在全球范围内才能被 Airflow 识别。

于 2017-10-26T17:28:05.570 回答