Minor improvment to tutorial example

This commit is contained in:
Maxime Beauchemin 2015-06-09 17:30:42 -07:00
Родитель 101af9393f
Коммит 5d540c9f7b
2 изменённых файлов: 16 добавлений и 2 удалений

Просмотреть файл

@ -16,6 +16,13 @@ default_args = {
'email': ['airflow@airflow.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_interval': timedelta(minutes=5),
# 'queue': 'bash_queue',
# 'pool': 'backfill',
# 'priority_weight': 10,
# 'schedule_interval': timedelta(1),
# 'end_date': datetime(2016, 1, 1),
}
dag = DAG('tutorial', default_args=default_args)

Просмотреть файл

@ -19,16 +19,23 @@ complicated, a line by line explanation follows below.
"""
from airflow import DAG
from airflow.operators import BashOperator
from datetime import datetime
from datetime import datetime, timedelta
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2015, 1, 1),
'start_date': datetime(2015, 6, 1),
'email': ['airflow@airflow.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_interval': timedelta(minutes=5),
# 'queue': 'bash_queue',
# 'pool': 'backfill',
# 'priority_weight': 10,
# 'schedule_interval': timedelta(1),
# 'end_date': datetime(2016, 1, 1),
}
dag = DAG('tutorial', default_args=default_args)