add workflow 泰克客户,dev
This commit is contained in:
parent
e9b28e7819
commit
d95d1f410c
|
@ -23,7 +23,7 @@ default_args = {
|
||||||
}
|
}
|
||||||
|
|
||||||
dag = DAG('wf_dag_tk_cust', default_args=default_args,
|
dag = DAG('wf_dag_tk_cust', default_args=default_args,
|
||||||
schedule_interval="0 0 * * *",
|
schedule_interval="30 18 * * 1",
|
||||||
catchup=False,
|
catchup=False,
|
||||||
dagrun_timeout=timedelta(minutes=160),
|
dagrun_timeout=timedelta(minutes=160),
|
||||||
max_active_runs=3)
|
max_active_runs=3)
|
||||||
|
@ -237,8 +237,6 @@ d_livechat_contact >> cust_contact_mapping
|
||||||
cust_contact_mapping >> cust_contact_info
|
cust_contact_mapping >> cust_contact_info
|
||||||
cust_contact_mapping >> cust_leads
|
cust_contact_mapping >> cust_leads
|
||||||
t01_crm_raw_leads >> cust_leads
|
t01_crm_raw_leads >> cust_leads
|
||||||
t00_china_city_info >> cust_contact_info
|
|
||||||
t00_country_info >> cust_contact_info
|
|
||||||
cust_leads >> cust_all_info
|
cust_leads >> cust_all_info
|
||||||
cust_contact_info >> cust_all_info
|
cust_contact_info >> cust_all_info
|
||||||
cust_all_info >> task_failed
|
cust_all_info >> task_failed
|
||||||
|
|
Loading…
Reference in New Issue