2017-05-29 2 views

Antwort

0

Sie Ihre dag erstellen können wie:

dag = DAG("Your_dag", default_args=default_args, schedule_interval="0 19 * * 1-4") 
+0

das ist für mon-thur aber ich brauche es um 11 am Freitag zu laufen. Wie nehme ich das auf? –

+0

Ich denke, du solltest es als zwei verschiedene DAG.another dag für 23 Uhr Freitag behandeln. –

0

Sie so etwas tun könnte:

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) 

Dies wird zwei erstellen DAGs aus einer einzigen Datei. DAGs müssen im globalen Geltungsbereich sein, um von Airflow erkannt zu werden.

Verwandte Themen