fix: 修复字段名search_keyword拼写错误并优化状态处理逻辑

移除对workflow_status和error的冗余状态检查
修正search_keyword为search_keywords以保持字段一致性
在decode_video中添加日志记录视频列表数据

decode_task/decodeTask.py

@@ -35,7 +35,7 @@ def get_decode_result_by_id(task_id:str):
     if not tasks:
         logger.info(f"task_id = {task_id} , 任务不存在")
         return None
-    return tasks['result'], tasks['status'],tasks['error_reason'],tasks['search_keyword']
+    return tasks['result'], tasks['status'],tasks['error_reason'],tasks['search_keywords']
 
 
 def  decode_task_status_handler():
@@ -74,8 +74,6 @@ def  decode_task_status_handler():
                     status_code = int(raw_status)
                 except Exception:
                     status_code = 3
-            elif decode_result.get("workflow_status") in ("failed", "incomplete") or decode_result.get("error"):
-                status_code = 3
             else:
                 status_code = 2
         else:

main.py

@@ -50,6 +50,7 @@ def startup_event():
 def decode_video(param:DecodeListParam):
 
     video_list = param.video_list
+    logger.info(f"数据池数据 = {video_list}")
     data_list = []
     for video in video_list:
         video_id = video.channel_content_id
@@ -83,7 +84,7 @@ def get_decode_result(param: TaskStatusParam):
             "message": "error",
             "data": None
         }
-    result, status,error_reason,search_keyword = db_res
+    result, status,error_reason,search_keywords = db_res
     if result:
         return {
             "code": 0,
@@ -92,7 +93,7 @@ def get_decode_result(param: TaskStatusParam):
                 "result": result,
                 "status": status,
                 "error":error_reason,
-                "searchKeyword":search_keyword
+                "searchKeyword":search_keywords
             }
         }
     else: