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

add workflow 市场-Agents调度,dev

This commit is contained in:
root 2025-12-09 18:19:22 +08:00
parent 2a6e295a87
commit 04cd1e14ab
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dev/workflow/TK_Cust/agents_market_newsletter/市场-Agents调度/wf_dag_agents_market_newsletter.py
View File

@ -90,7 +90,17 @@ depends_on_past=False,
retries=1,
dag=dag)
a_market_Intelligence_newsletter = SSHOperator(
ssh_hook=sshHook,
task_id='a_market_Intelligence_newsletter',
command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} ',
params={'my_param':"a_market_Intelligence_newsletter_agi"},
depends_on_past=False,
retries=3,
dag=dag)
agents_market_summar >> tk_product_prefer
agents_market_summar >> batch_gen_crawer
agents_recuriments >> batch_gen_recruiment
batch_gen_recruiment >> task_failed
batch_gen_crawer >> a_market_Intelligence_newsletter
a_market_Intelligence_newsletter >> tk_product_prefer
tk_product_prefer >> task_failed