DAG: ppz_project_dag

schedule: 00 05,10 * * *

ppz_project_dag

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
30
31
32
from airflow.operators.bash_operator import BashOperator
from airflow import DAG
from datetime import datetime, timedelta


args = {
    'owner': 'lidayuan',
    'start_date': datetime(2022, 12, 29),
    'email': 'gaoqiang@lenztechretail.com',
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 3,
    'retry_delay': timedelta(minutes=1),
}

dag = DAG(
    dag_id='ppz_project_dag',
    default_args=args,
    schedule_interval='00 05,10 * * *',
    dagrun_timeout=timedelta(minutes=200))


#君乐宝项目执行程序
#junlebao_dag_1=BashOperator(task_id="junlebao_dag1",bash_command='cd /usr/local/airflow/dags/bi_etl/bi_project_airflow/project_common/;nohup python junlebao/junlebao_delete.py &',dag=dag)

junlebao_dag_2=BashOperator(task_id="junlebao_dag2",bash_command='cd /usr/local/airflow/dags/bi_etl/bi_project_airflow/project_common/;nohup python junlebao/junlebao_data_deal_v1.py &',dag=dag)


jierou_dag1=BashOperator(task_id="jierou_dag1",bash_command='cd /usr/local/airflow/dags/bi_etl/bi_project_airflow/project_common/;nohup python jierou/jierou_data_deal_v1.py &',dag=dag)

#junlebao_dag_1.set_downstream(junlebao_dag_2)
junlebao_dag_2.set_downstream(jierou_dag1)