yumoqing/pipeline-sdlc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: bypass pipeline_submit, create tasks directly in cockpit

Browse Source
This commit is contained in:
yumoqing 2026-08-02 17:56:06 +08:00
parent 40afce18e7
commit 28820a0b29
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
wwwroot/api/cockpit_chat.dspy
View File

@ -358,14 +358,15 @@ if action == 'send_message':
title = intent.get('title', '') or message_text[:100]
task_params = {'description': intent.get('description', ''), 'input_text': message_text}
try:
result = await pipeline_submit(org_id, 'sdlc_general', uid, title, task_params)
rd = json.loads(result)
if rd.get('success'):
task_id = rd.get('task_id', '')
await _save_context(sor, uid, pid, iid)
agent_reply = f"✅ 任务「{title}」已提交（{task_id}），产线开始执行。"
else:
agent_reply = f"任务提交失败：{rd.get('message', '未知错误')}"
# Direct task creation (bypass pipeline_submit to avoid executor issues)
task_id = getID()
await sor.C('pipeline_tasks', {
'id': task_id, 'tenant_id': org_id, 'pipeline_id': 'sdlc_general',
'owner_id': uid, 'title': title, 'state': 'submitted',
'params': json.dumps(task_params, ensure_ascii=False)
})
await _save_context(sor, uid, pid, iid)
agent_reply = f"✅ 任务「{title}」已提交（{task_id}）。"
except Exception as e:
agent_reply = f"任务提交失败：{str(e)[:200]}"
elif intent_type == 'add_bug':