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={