From 5ed7198a8a2b74b767d4455be9e518a284f5dd29 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Fri, 13 Dec 2024 12:15:15 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=BC=80=E5=A7=8B=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 biz/task.py |  1 +
 util/api.py | 10 ++++++++++
 2 files changed, 11 insertions(+)

diff --git a/biz/task.py b/biz/task.py
index e8d9ab4..2eaf62f 100644
--- a/biz/task.py
+++ b/biz/task.py
@@ -10,6 +10,7 @@ def normalize_task(task_info):
 def start_task(task_info):
     from biz.ffmpeg import parse_ffmpeg_task, start_ffmpeg_task, clear_task_tmp_file
     task_info = normalize_task(task_info)
+    api.report_task_start(task_info)
     template_info = get_template_def(task_info.get("templateId"))
     ffmpeg_task = parse_ffmpeg_task(task_info, template_info)
     result = start_ffmpeg_task(ffmpeg_task)
diff --git a/util/api.py b/util/api.py
index fbe581d..9e04b75 100644
--- a/util/api.py
+++ b/util/api.py
@@ -107,6 +107,16 @@ def report_task_success(task_info):
         return None
 
 
+def report_task_start(task_info):
+    try:
+        response = session.post('{0}/{1}/start'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={
+            'accessKey': os.getenv('ACCESS_KEY'),
+        }, timeout=10)
+    except requests.RequestException as e:
+        logger.error("请求失败！", e)
+        return None
+
+
 def report_task_failed(task_info):
     try:
         response = session.post('{0}/{1}/fail'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={