diff --git a/dev/workflow/TK_Cust/partner1site/partner1site/wf_dag_partner1site.py b/dev/workflow/TK_Cust/partner1site/partner1site/wf_dag_partner1site.py index b9b68ef..396ab2e 100644 --- a/dev/workflow/TK_Cust/partner1site/partner1site/wf_dag_partner1site.py +++ b/dev/workflow/TK_Cust/partner1site/partner1site/wf_dag_partner1site.py @@ -37,7 +37,7 @@ task_failed = EmailOperator ( cc=[""], subject="partner1site_failed", html_content='

您好,partner1site作业失败,请及时处理"

') - + part_summary_visit_feign = SSHOperator( ssh_hook=sshHook, task_id='part_summary_visit_feign', @@ -56,16 +56,16 @@ retries=3, dag=dag) part_summary_visit_feign >> part_summary_visit_load - + partner_summary_visit_9060 = SSHOperator( ssh_hook=sshHook, task_id='partner_summary_visit_9060', -command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', +command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} ', params={'my_param':"S98_S_partner_summary_visit"}, depends_on_past=False, retries=3, dag=dag) - + part_summary_report_feign = SSHOperator( ssh_hook=sshHook, task_id='part_summary_report_feign', @@ -84,16 +84,16 @@ retries=3, dag=dag) part_summary_report_feign >> part_summary_report_load - + partner_summary_report_6257 = SSHOperator( ssh_hook=sshHook, task_id='partner_summary_report_6257', -command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', +command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} ', params={'my_param':"S98_S_partner_summary_report"}, depends_on_past=False, retries=3, dag=dag) - + part_summary_pos_feign = SSHOperator( ssh_hook=sshHook, task_id='part_summary_pos_feign', @@ -112,7 +112,7 @@ retries=3, dag=dag) part_summary_pos_feign >> part_summary_pos_load - + partner_summary_pos_4937 = SSHOperator( ssh_hook=sshHook, task_id='partner_summary_pos_4937', @@ -121,7 +121,7 @@ params={'my_param':"S98_S_partner_summary_pos"}, depends_on_past=False, retries=3, dag=dag) - + part_summary_custome_feign = SSHOperator( ssh_hook=sshHook, task_id='part_summary_custome_feign', @@ -140,7 +140,7 @@ retries=3, dag=dag) part_summary_custome_feign >> part_summary_custome_load - + partner_summary_customer_5702 = SSHOperator( ssh_hook=sshHook, task_id='partner_summary_customer_5702', @@ -149,9 +149,9 @@ params={'my_param':"S98_S_partner_summary_customer"}, depends_on_past=False, retries=3, dag=dag) - -part_summary_visit_load >> partner_summary_visit_9060 -part_summary_report_load >> partner_summary_report_6257 -part_summary_pos_load >> partner_summary_pos_4937 -part_summary_custome_load >> partner_summary_customer_5702 -partner_summary_customer_5702 >> task_failed + +part_summary_visit_load >> partner_summary_visit_9060 +part_summary_report_load >> partner_summary_report_6257 +part_summary_pos_load >> partner_summary_pos_4937 +part_summary_custome_load >> partner_summary_customer_5702 +partner_summary_customer_5702 >> task_failed