add workflow 天润Dynamic邮件周一同步,dev

dev/workflow/TK_Cust/dag_email_data_export_monday/天润Dynamic邮件周一同步/wf_dag_dag_email_data_export_monday.py

@@ -60,5 +60,14 @@ dag=dag)
 
 
 
+f_ccc_work_ticket_integ = SSHOperator(
+ssh_hook=sshHook,
+task_id='f_ccc_work_ticket_integ',
+command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
+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
-dysql_update_dynamic_email_data >> task_failed 
+f_ccc_work_ticket_integ >> uds_dynamic_data_export
+uds_dynamic_data_export >> task_failed