This commit is contained in:
Jerry Yan 2025-03-30 18:11:03 +08:00
parent 6e4dbfd843
commit ced0c1ad1e

View File

@ -11,9 +11,8 @@ from util import api
def start_task(task_info): def start_task(task_info):
tracer = get_tracer(__name__) tracer = get_tracer(__name__)
with tracer.start_as_current_span("start_task") as span: with tracer.start_as_current_span("start_task") as span:
span.set_attribute("task.id", task_info)
task_info = api.normalize_task(task_info) task_info = api.normalize_task(task_info)
span.set_attribute("task.info", json.dumps(task_info)) span.set_attribute("task", json.dumps(task_info))
template_info = get_template_def(task_info.get("templateId")) template_info = get_template_def(task_info.get("templateId"))
api.report_task_start(task_info) api.report_task_start(task_info)
ffmpeg_task = parse_ffmpeg_task(task_info, template_info) ffmpeg_task = parse_ffmpeg_task(task_info, template_info)