Update api.py

api.py

@@ -58,10 +58,14 @@ async def delete_files(directory: str):
 ########异步处理py文件执行接口
 def file_executer(file_name:str)->"执行返回":
     try:
+        print("开始执行py任务",file_name)
         result = subprocess.check_output(["python", f"{file_name}.py"]).decode("utf-8")
-        print("执行完成py任务:",file_name)
+        print("执行完成py任务:",file_name,"结果如下")
+        print(PlainTextResponse(result))
         return PlainTextResponse(result)
     except subprocess.CalledProcessError as e:
+        print("执行py任务失败",file_name,"原因如下")
+        print(PlainTextResponse(f"Error executing {file_name}.py: {e}"))
         return PlainTextResponse(f"Error executing {file_name}.py: {e}")
     
 @app.get("/execute_py_file/{file_name}")
@@ -73,6 +77,17 @@ async def execute_py_file(file_name: str,background_tasks: BackgroundTasks):
 
 
 
+#收到图片后为了后台任务的顺序,单独设定一个函数依次将1去水印，2裁剪,3合并按照顺序加入后台任务队列
+@app.get("/execute_all_task")
+async def execute_all_task(background_tasks: BackgroundTasks):
+    background_tasks.add_task(file_executer,"1removeMask")
+    background_tasks.add_task(file_executer,"2magiDialogCut")
+    background_tasks.add_task(file_executer,"3mergeDialogToVideo")
+    return {"message": "Tasks added to the queue"}
+
+
+
+
 
 
 ##########异步样例