Update api.py

api.py

@@ -112,10 +112,10 @@ async def execute_all_task(background_tasks: BackgroundTasks,file_list: list = [
         #如果请求中设置允许上传output.mp4
         cover_img = cover_image.file.read()
         cover_img_data = Image.open(io.BytesIO(img)).convert("L").convert("RGB")
-        path_to_image = os.path.join(cover_path, f"cover.jpg")
-        cover_img_data.save(path_to_image)
+        cover_path_to_image = os.path.join(cover_path, f"cover.jpg")
+        cover_img_data.save(cover_path_to_image)
         #video数据从meta用户请求获取,至于
-        background_tasks.add_task(upload_video, bili_meta_data)
+        background_tasks.add_task(upload_video, bili_meta_data,cover_path_to_image)
         return {"message": "提交video任务已加入队列"}
         
     return {"message": "Tasks added to the queue"}
@@ -141,7 +141,7 @@ def returnRandomSubscribeUrl(background_tasks: BackgroundTasks)->str:
 
 
 
-async def upload_video():
+async def upload_video(meta:dict,cover_path_to_image:str):
     credential = Credential(sessdata=sessdata,
                             bili_jct=bili_jct,
                             buvid3=buvid3)
@@ -149,7 +149,7 @@ async def upload_video():
     
     page = video_uploader.VideoUploaderPage(path='mp4_out/output_video.mp4', title=meta['title'], description=meta['desc'])
     
-    uploader = video_uploader.VideoUploader([page], meta, credential, cover='cover.jpg')
+    uploader = video_uploader.VideoUploader([page], meta, credential, cover=cover_path_to_image)
 
     @uploader.on("__ALL__")
     async def ev(data):