diff --git a/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py b/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py index d2f4c6e..fc988a7 100644 --- a/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py +++ b/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py @@ -41,16 +41,6 @@ task_failed = EmailOperator ( html_content='

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

') -agents_recuriments = SSHOperator( -ssh_hook=sshHook, -task_id='agents_recuriments', -command='cd /data/airflow/etl/agents && python agents_recuriments.py', -params={'my_param':"agents_recuriments"}, -depends_on_past=False, -retries=1, -dag=dag) - - agents_market_summar = SSHOperator( ssh_hook=sshHook, task_id='agents_market_summar', @@ -70,26 +60,6 @@ depends_on_past=False, retries=1, dag=dag) - -batch_gen_crawer = SSHOperator( -ssh_hook=sshHook, -task_id='batch_gen_crawer', -command='cd /data/airflow/etl/agents && python batch_gen_crawer.py', -params={'my_param':"batch_gen_crawer"}, -depends_on_past=False, -retries=1, -dag=dag) - - -batch_gen_recruiment = SSHOperator( -ssh_hook=sshHook, -task_id='batch_gen_recruiment', -command='cd /data/airflow/etl/agents && python batch_gen_recruiment.py', -params={'my_param':"batch_gen_recruiment"}, -depends_on_past=False, -retries=1, -dag=dag) - a_market_Intelligence_newsletter = SSHOperator( ssh_hook=sshHook, task_id='a_market_Intelligence_newsletter', @@ -135,13 +105,10 @@ dag=dag) agents_market_summar >> tk_product_prefer -agents_market_summar >> batch_gen_crawer -agents_recuriments >> batch_gen_recruiment a_market_Intelligence_newsletter >> tk_product_prefer tk_product_prefer >> dysql_news_letter_info agents_market_summar >> a_market_Intelligence_newsletter tk_product_prefer >> dysql_recruitment_news_letter dysql_enterprise_card_newsletter >> dysql_recruitment_news_letter -agents_recuriments >> tk_product_prefer tk_product_prefer >> dysql_enterprise_card_newsletter dysql_enterprise_card_newsletter >> task_failed