add workflow 天润dynamic邮件同步,dev

dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py

@@ -24,7 +24,7 @@ default_args = {
 }
 
 dag = DAG('wf_dag_smart_ccc_dynamic_email', default_args=default_args,
-schedule_interval="5 10,14,16,12,18 * * *",
+schedule_interval="5 10,14,16,12,18 * * 1-5",
 catchup=False,
 dagrun_timeout=timedelta(minutes=160),
 max_active_runs=3)
@@ -37,7 +37,7 @@ task_failed = EmailOperator (
     cc=[""],
     subject="smart_ccc_dynamic_email_failed",
     html_content='<h3>您好，smart_ccc_dynamic_email作业失败，请及时处理" </h3>')
-
+
 
 dysql_update_dynamic_email_data = SSHOperator(
 ssh_hook=sshHook,
@@ -49,7 +49,7 @@ retries=3,
 dag=dag)
 
 
-
+
 
 uds_dynamic_data_export = SSHOperator(
 ssh_hook=sshHook,
@@ -59,7 +59,7 @@ params={'my_param':"uds_dynamic_data_export"},
 depends_on_past=False, 
 retries=3, 
 dag=dag)
-
+
 f_ccc_work_ticket_integ = SSHOperator(
 ssh_hook=sshHook,
 task_id='f_ccc_work_ticket_integ',
@@ -67,7 +67,7 @@ command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >
 params={'my_param':"f_ccc_work_ticket_integ_agi"},
 depends_on_past=False, 
 retries=3, 
-dag=dag)
-uds_dynamic_data_export >> dysql_update_dynamic_email_data
-f_ccc_work_ticket_integ >> uds_dynamic_data_export
-uds_dynamic_data_export >> task_failed 
+dag=dag)
+uds_dynamic_data_export >> dysql_update_dynamic_email_data
+f_ccc_work_ticket_integ >> uds_dynamic_data_export
+uds_dynamic_data_export >> task_failed