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-11-20 11:36:50 +08:00
parent 797da86088
commit 3eff6e0b1c
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dev/workflow/TK_Cust/agents_market_newsletter/泰克产品相关性分析/tk_product_prefer.py
View File

@ -121,7 +121,8 @@ class APIClient:
"inputs": {}, "inputs": {},
"query" : query, "query" : query,
"response_mode": "streaming", "response_mode": "streaming",
"user": "admin" "user": "admin",
"conversation_id":""
}) })
try: try:
@ -162,7 +163,8 @@ class APIClient:
"inputs": {}, "inputs": {},
"query":"", "query":"",
"response_mode": "streaming", "response_mode": "streaming",
"user": "admin" "user": "admin",
"conversation_id":""
} }
# 添加其他参数 # 添加其他参数
@ -294,7 +296,7 @@ def main():
inputs_data = { inputs_data = {
"urls": f"{text}" "urls": f"{text}"
} }
logger.info(f"调用call_api_with_inputs")
result = api_client.call_api_with_inputs(inputs_data) result = api_client.call_api_with_inputs(inputs_data)
if result['success']: if result['success']:
@ -306,6 +308,7 @@ def main():
else: else:
#agent #agent
query = text query = text
logger.info(f"call_api_with_query")
result = api_client.call_api_with_query(query) result = api_client.call_api_with_query(query)
if result['success']: if result['success']: