2017-07-24 33 views
0

我試圖安排每天以3小時爲間隔動態運行的作業,從13:45開始到14:30結束。 我的代碼如下:如何使用start_date和End_date安排氣流作業?

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)) 

不能與起始日期日期和結束日期運行,但它運行在正常的5個mintes間隔, 請在本期

+0

那你的意思是不是能與起始日期日期和結束日期運行,但它運行在正常的5個mintes間隔,請在此問題的幫助開發: 它沒有運行,它不會停止在end_date?或會發生什麼? –

+0

它沒有拿起我提到的start_date,time和end_date,time,只是工作時間間隔(我提到5分鐘)在調度 –

+0

仍然不明白髮生了什麼。 –

回答