1

我正在尝试安排每天以 3 小时为间隔动态运行的作业，从 13:45 开始，到 14:30 PM 结束。我的代码如下：

Test = datetime.now()

current_date = datetime.now()

default_args = {

'owner': 'abc',

'depends_on_past': False,

'start_date': datetime(Test.year, Test.month,Test.day, 13, 45),

'retries': 1,

'retry_delay': timedelta(minutes=5),

'queue': 'bash_queue',

'end_date': datetime(Test.year, Test.month,Test.day,14,30),

}

dag = DAG('CSVDataFile', default_args=default_args, schedule_interval=timedelta(minutes=5))

无法使用 start_date 和 end_date 运行，但它以正常的 5 分钟间隔运行，请帮助解决此问题

4

1 回答 1

0

如果您使用的是以上 Airflow 1.8，请根据更新日志提供固定的 start_time：https ://github.com/apache/incubator-airflow/blob/master/UPDATING.md#less-forgiving-scheduler-on-dynamic- start_date
另外，请尝试确保它在 UTC 下。

以 UTC 运行您的整个 Airflow 基础架构。Airflow 是在 Airbnb 开发的，每个系统都在 UTC (GMT) 上运行

于 2017-07-25T01:33:26.337 回答