|
|
@@ -194,18 +194,11 @@ def task_exe_step_stat_query(ts: int, workflow_id: str) -> List[Dict[str, Any]]:
|
|
|
when status = 1 then '运行中'
|
|
|
when status = 2 then '成功'
|
|
|
when status = 3 then '失败'
|
|
|
- when swt.task_status = 0 then '初始化'
|
|
|
- when swt.task_status = 1 then '运行中'
|
|
|
- when swt.task_status = 2 then '成功'
|
|
|
- when swt.task_status = 3 then '失败'
|
|
|
else '未知' end AS status,
|
|
|
case
|
|
|
when swtes.error_msg like '%Data too long%' then '数据超过字段长度限制'
|
|
|
when swtes.error_msg like '%Deadlock%' then '数据库死锁'
|
|
|
when (swtes.error_msg <> '' and swtes.error_msg is not null) then substring_index(swtes.error_msg, ',', 1)
|
|
|
- when swt.error_msg like '%Data too long%' then '数据超过字段长度限制'
|
|
|
- when swt.error_msg like '%Deadlock%' then '数据库死锁'
|
|
|
- when (swt.error_msg <> '' AND swt.error_msg is not null) then substring_index(swt.error_msg, ',', 1)
|
|
|
else '' end AS error_msg
|
|
|
from supply_workflow_task swt
|
|
|
left join supply_workflow_task_exe_step swtes on swt.task_id = swtes.task_id
|
