Browse Source

fix: 优化任务状态处理和日志输出

改进decode_task_status_handler中的日志信息,显示具体任务id而非整个任务对象
在get_decode_result接口中添加日志记录查询结果,并修正状态判断逻辑
调整错误返回信息,使用实际状态码和错误原因
max_liu 3 days ago
parent
commit
f24e9ea5cc
2 changed files with 8 additions and 5 deletions
  1. 2 2
      decode_task/decodeTask.py
  2. 6 3
      main.py

+ 2 - 2
decode_task/decodeTask.py

@@ -43,10 +43,10 @@ def  decode_task_status_handler():
     sql = "SELECT * FROM decode_record WHERE task_status = 0 ORDER BY create_timestamp ASC LIMIT 1"
     task = mysql.fetchone(sql)
    
-    logger.info(f"开始执行任务 = {task}")
+    logger.info(f"开始执行任务id = {task['task_id']}")
 
     if not task:
-        logger.info("任务列表为空")
+        logger.info("没有status为0的任务了")
         return
     else:
         task_id = task['task_id']

+ 6 - 3
main.py

@@ -78,6 +78,9 @@ def decode_video(param:DecodeListParam):
 @app.post("/decode/result")
 def get_decode_result(param: TaskStatusParam):
     db_res = get_decode_result_by_id_db(param.task_id)
+    logger.info(f"\n查询结构结果的task_id = {param.task_id}")
+    logger.info(f"\n查询结构结果 = {db_res}")
+
     if not db_res:
         return {
             "code": -1,
@@ -85,7 +88,7 @@ def get_decode_result(param: TaskStatusParam):
             "data": None
         }
     result, status,error_reason,search_keywords = db_res
-    if result:
+    if status == 2:
         return {
             "code": 0,
             "message": "success",
@@ -98,8 +101,8 @@ def get_decode_result(param: TaskStatusParam):
         }
     else:
         return {
-            "code": -1,
-            "message": "error",
+            "code": status,
+            "message": error_reason,
             "data": None
         }