From da6579a9ed780ee3e135ac62877a2190800cc81b Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Thu, 26 Dec 2024 16:42:18 +0800
Subject: [PATCH] 2

---
 util/api.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/util/api.py b/util/api.py
index c2773c3..1380c29 100644
--- a/util/api.py
+++ b/util/api.py
@@ -24,6 +24,7 @@ def sync_center():
             'accessKey': os.getenv('ACCESS_KEY'),
             'clientStatus': util.system.get_sys_info()
         }, timeout=10)
+        response.raise_for_status()
     except requests.RequestException as e:
         logger.error("请求失败！", e)
         return []
@@ -49,6 +50,7 @@ def get_template_info(template_id):
         response = session.post('{0}/template/{1}'.format(os.getenv('API_ENDPOINT'), template_id), json={
             'accessKey': os.getenv('ACCESS_KEY'),
         }, timeout=10)
+        response.raise_for_status()
     except requests.RequestException as e:
         logger.error("请求失败！", e)
         return None
@@ -107,6 +109,7 @@ def report_task_success(task_info):
         response = session.post('{0}/{1}/success'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={
             'accessKey': os.getenv('ACCESS_KEY'),
         }, timeout=10)
+        response.raise_for_status()
     except requests.RequestException as e:
         logger.error("请求失败！", e)
         return None
@@ -117,6 +120,7 @@ def report_task_start(task_info):
         response = session.post('{0}/{1}/start'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={
             'accessKey': os.getenv('ACCESS_KEY'),
         }, timeout=10)
+        response.raise_for_status()
     except requests.RequestException as e:
         logger.error("请求失败！", e)
         return None
@@ -127,6 +131,7 @@ def report_task_failed(task_info):
         response = session.post('{0}/{1}/fail'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={
             'accessKey': os.getenv('ACCESS_KEY'),
         }, timeout=10)
+        response.raise_for_status()
     except requests.RequestException as e:
         logger.error("请求失败！", e)
         return None
@@ -137,6 +142,7 @@ def upload_task_file(task_info, ffmpeg_task):
         response = session.post('{0}/{1}/uploadUrl'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={
             'accessKey': os.getenv('ACCESS_KEY'),
         }, timeout=10)
+        response.raise_for_status()
     except requests.RequestException as e:
         logger.error("请求失败！", e)
         return False