add workflow 招聘信息导入,dev

dev/workflow/TK_Cust/agent_recruitment/招聘信息导入/wf_dag_agent_recruitment.py

@@ -50,4 +50,13 @@ depends_on_past=False,
 retries=1, 
 dag=dag)
 
-batch_gen_recruiment >> task_failed 
+a_recruitment_intelligence = SSHOperator(
+ssh_hook=sshHook,
+task_id='a_recruitment_intelligence',
+command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}}  ',
+params={'my_param':"a_recruitment_intelligence_agi"},
+depends_on_past=False, 
+retries=3, 
+dag=dag)
+batch_gen_recruiment >> a_recruitment_intelligence
+a_recruitment_intelligence >> task_failed