diff --git a/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py b/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py index bb06b26..53e99ff 100644 --- a/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py +++ b/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py @@ -110,82 +110,8 @@ params={'my_param':"t01_ccc_cust_info_agi"}, depends_on_past=False, retries=3, dag=dag) - -dysql_ccc_scrm_cust_label_info = SSHOperator( -ssh_hook=sshHook, -task_id='dysql_ccc_scrm_cust_label_info', -command='/data/airflow/etl/MART/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ', -params={'my_param':"dysql_ccc_scrm_cust_label_info"}, -depends_on_past=False, -retries=3, -dag=dag) - - - -huiju_tags_feign = SSHOperator( -ssh_hook=sshHook, -task_id='huiju_tags_feign', -command='python3 /data/airflow/etl/API/huiju_tags_feign.py', -depends_on_past=False, -retries=3, -dag=dag) - -huiju_tags_load = SSHOperator( -ssh_hook=sshHook, -task_id='huiju_tags_load', -command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}', -params={'my_param':"huiju_tags_load"}, -depends_on_past=False, -retries=3, -dag=dag) - -huiju_tags_feign >> huiju_tags_load - -scrm_tags_5000 = SSHOperator( -ssh_hook=sshHook, -task_id='scrm_tags_5000', -command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', -params={'my_param':"S98_S_scrm_tags"}, -depends_on_past=False, -retries=3, -dag=dag) - - -uds_crm_tag_update = SSHOperator( -ssh_hook=sshHook, -task_id='uds_crm_tag_update', -command='python /data/airflow/etl/Python/crm_tag_update.py', -params={'my_param':"uds_crm_tag_update"}, -depends_on_past=False, -retries=3, -dag=dag) - -t01_scrm_label = SSHOperator( -ssh_hook=sshHook, -task_id='t01_scrm_label', -command='/data/airflow/etl/PDM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ', -params={'my_param':"t01_scrm_label_agi"}, -depends_on_past=False, -retries=3, -dag=dag) -cust_label_rela = SSHOperator( -ssh_hook=sshHook, -task_id='cust_label_rela', -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':"cust_label_rela_agi"}, -depends_on_past=False, -retries=3, -dag=dag) customer_labels_load >> tr_custom_labels_8280 customer_list_load >> tr_custom_details_5516 tr_custom_labels_8280 >> t01_ccc_cust_label tr_custom_details_5516 >> t01_ccc_cust_info -t01_ccc_cust_label >> dysql_ccc_scrm_cust_label_info -t01_ccc_cust_info >> dysql_ccc_scrm_cust_label_info -huiju_tags_load >> scrm_tags_5000 -dysql_ccc_scrm_cust_label_info >> uds_crm_tag_update -t01_scrm_label >> cust_label_rela -scrm_tags_5000 >> t01_scrm_label -cust_label_rela >> uds_crm_tag_update -cust_label_rela >> dysql_ccc_scrm_cust_label_info -dysql_ccc_scrm_cust_label_info >> task_failed +t01_ccc_cust_info >> task_failed