Update api.py

api.py

@@ -102,31 +102,6 @@ async def execute_py_file(file_name: str,background_tasks: BackgroundTasks):
 
 
 #保证既要提交队列后返回给用户,又要先完成前面的video生成步骤再执行后面的submit函数,还有兼顾allow_submit的值
-
-# @app.get("/execute_all_task")
-# async def execute_all_task(background_tasks: BackgroundTasks, file_list: List[str] = Query(["1removeMask", "2magiDialogCut", "3mergeDialogToVideo"]),
-#                            bili_meta_data: dict = None, cover_image: UploadFile = File(...), mp4_out_file: str = 'mp4_out/output.mp4',
-#                            allow_submit: bool = False, cover_path: str = '/cover'
-#                            ):
-#     print("获取到file_list是：", file_list)
-#     tasks = []
-#     for file_name in file_list:
-#         tasks.append(file_executer(file_name))
-
-#     # await asyncio.gather(*tasks) #尝试不用这个能否运行,老是这里报错
-
-#     if allow_submit:
-#         cover_img = cover_image.file.read()
-#         cover_img_data = Image.open(io.BytesIO(cover_img)).convert("L").convert("RGB")
-#         cover_path_to_image = os.path.join(cover_path, f"cover.jpg")
-#         cover_img_data.save(cover_path_to_image)
-#         background_tasks.add_task(upload_video, bili_meta_data, cover_path_to_image)
-#         return {"message": "提交video任务已加入队列"}
-
-#     return {"message": "Tasks added to the queue"}
-
-
-
 @app.get("/execute_all_task")
 async def execute_all_task(background_tasks: BackgroundTasks, file_list: List[str] = Query(["1removeMask", "2magiDialogCut", "3mergeDialogToVideo"]),
                            bili_meta_data: dict = None, cover_image: UploadFile = File(...), mp4_out_file: str = 'mp4_out/output.mp4',
@@ -137,6 +112,7 @@ async def execute_all_task(background_tasks: BackgroundTasks, file_list: List[st
     return {"message": "提交成功"}
 
 def process_tasks_and_upload(file_list, bili_meta_data, cover_image, cover_path,background_tasks):
+    print("获取到的用户bili_meta_data是:",bili_meta_data)
     tasks = []
     for file_name in file_list:
         tasks.append(file_executer(file_name))