dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow SCRM标签信息,dev

This commit is contained in:
root 2024-07-15 10:08:02 +08:00
parent c57fc02bf5
commit a6b87a4041
1 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
dev/workflow/TK_Cust/crm_tags/SCRM标签信息/wf_dag_crm_tags.py
View File

@ -37,7 +37,7 @@ task_failed = EmailOperator (
cc=[""], cc=[""],
subject="crm_tags_failed", subject="crm_tags_failed",
html_content='<h3>您好，crm_tags作业失败，请及时处理" </h3>') html_content='<h3>您好，crm_tags作业失败，请及时处理" </h3>')
huiju_tags_feign = SSHOperator( huiju_tags_feign = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='huiju_tags_feign', task_id='huiju_tags_feign',
@ -56,17 +56,17 @@ retries=3,
dag=dag) dag=dag)
huiju_tags_feign >> huiju_tags_load huiju_tags_feign >> huiju_tags_load
uds_crm_tag_update = SSHOperator(
ssh_hook=sshHook, # uds_crm_tag_update = SSHOperator(
task_id='uds_crm_tag_update', # ssh_hook=sshHook,
command='python /data/airflow/etl/Python/update_crm_tags.py', # task_id='uds_crm_tag_update',
params={'my_param':"uds_crm_tag_update"}, # command='python /data/airflow/etl/Python/crm_tag_update.py',
depends_on_past=False, # params={'my_param':"uds_crm_tag_update"},
retries=3, # depends_on_past=False,
dag=dag) # retries=3,
# dag=dag)
scrm_tags_5000 = SSHOperator( scrm_tags_5000 = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='scrm_tags_5000', task_id='scrm_tags_5000',
@ -75,7 +75,9 @@ params={'my_param':"S98_S_scrm_tags"},
depends_on_past=False, depends_on_past=False,
retries=3, retries=3,
dag=dag) dag=dag)
huiju_tags_load >> scrm_tags_5000 huiju_tags_load >> scrm_tags_5000
scrm_tags_5000 >> uds_crm_tag_update scrm_tags_5000 >> task_failed
uds_crm_tag_update >> task_failed
# scrm_tags_5000 >> uds_crm_tag_update
# uds_crm_tag_update >> task_failed