add workflow partner数据导入,dev

dev/workflow/TK_Cust/partner_one_site_file/partner数据导入/wf_dag_partner_one_site_file.py

@@ -58,5 +58,16 @@ retries=3,
 dag=dag)
 
 
+file_report_daily_complet = SSHOperator(
+ssh_hook=sshHook,
+task_id='file_report_daily_complet',
+command='python /data/airflow/bin/FILELOD.py {{ params.my_param }} {{ ds_nodash }}  >>/data/airflow/logs/file_load/file_load_{{ds_nodash}}.log 2>&1 ',
+params={'my_param':"report_daily_complet"},
+depends_on_past=False, 
+retries=3, 
+dag=dag)
+
+
 file_visits_ytd >> task_failed 
 file_report_daily_checked >> task_failed 
+file_report_daily_complet >> task_failed