DAG: pnghk_week

schedule: 00 17 * * *

pnghk_week

Toggle wrap 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
from airflow.operators.bash_operator import BashOperator
from airflow import DAG
from datetime import datetime, timedelta



args = {
    'owner': 'liangning',
    'start_date': datetime(2020, 4, 18),
    'email': 'ning.liang@traxretail.com',
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 3,
    'retry_delay': timedelta(minutes=1),
}

dag = DAG(
    dag_id='pnghk_week',
    default_args=args,
    schedule_interval='00 17 * * *',
    dagrun_timeout=timedelta(minutes=200))

t1=BashOperator(task_id="pnghk_api",bash_command='cd /usr/local/airflow/dags/bi_etl/pnghk_week/;nohup python api.py &',dag=dag)

t2=BashOperator(task_id="pnghk_url",bash_command='cd /usr/local/airflow/dags/bi_etl/pnghk_week/;nohup python api_url.py &',dag=dag)

t1.set_downstream(t2)

#t0=BashOperator(task_id="sleep",bash_command='sleep 1', retries=3 ,dag=dag)