feat:fix

monitor/supply_workflow_monitor.py

@@ -270,19 +270,12 @@ def crawler_and_produce_stat_query(ts: int, workflow_id: str) -> List[Dict[str,
                                          when swcpr.status = 0 then '初始化'
                                          when swcpr.status = 1 then '运行中'
                                          when swcpr.status = 2 then '成功'
-                                         when swcpr.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 '失败'
+                                         when swcpr.status = 3 then '失败' 
                                          else '未知' end   AS status,
                                      case
                                          when swcpr.error_msg like '%Data too long%' then '数据超过字段长度限制'
                                          when swcpr.error_msg like '%Deadlock%' then '数据库死锁'
-                                         when (swcpr.error_msg <> '' AND swcpr.error_msg is not null) then substring_index(swcpr.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)
+                                         when (swcpr.error_msg <> '' AND swcpr.error_msg is not null) then substring_index(swcpr.error_msg, ',', 1) 
                                          else '' 
                                          end               AS error_msg
                               from supply_workflow_task swt
@@ -306,18 +299,11 @@ def crawler_and_produce_stat_query(ts: int, workflow_id: str) -> List[Dict[str,
                                          when swppr.status = 1 then '运行中'
                                          when swppr.status = 2 then '成功'
                                          when swppr.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 swppr.error_msg like '%Data too long%' then '数据超过字段长度限制'
                                          when swppr.error_msg like '%Deadlock%' then '数据库死锁'
                                          when (swppr.error_msg <> '' and swppr.error_msg is not null) then substring_index(swppr.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