From cdf46458be191fa037ce602619d5a4adb63ad354 Mon Sep 17 00:00:00 2001 From: root Date: Sat, 23 Apr 2022 05:49:33 +0800 Subject: [PATCH] fix workflow info and redo func --- controller/api/workflow_blueprint.py | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/controller/api/workflow_blueprint.py b/controller/api/workflow_blueprint.py index a0f3a6a..9b86fb1 100644 --- a/controller/api/workflow_blueprint.py +++ b/controller/api/workflow_blueprint.py @@ -21,7 +21,7 @@ def get_workflow_info(workflow_id): workflow = Workflow.query.get(workflow_id) if workflow is None: return not_found_json_response(id=workflow_id) - return jsonify(workflow) + return jsonify(workflow.to_dict()) @blueprint.put("/") @@ -69,10 +69,12 @@ def start_workflow(workflow_id): workflow = Workflow.query.get(workflow_id) if workflow is None: return not_found_json_response(id=workflow_id) - if len(workflow.video_clips) > 0 and len(workflow.danmaku_clips) > 0: - threading.Thread(target=do_workflow, args=( - workflow.video_clips[0].full_path, - workflow.danmaku_clips[0].full_path, - *[clip.full_path for clip in workflow.danmaku_clips[1:]] - )).start() + if len(workflow.video_clips) > 0: + for video_clip in workflow.video_clips: + if len(video_clip.danmaku_clips) > 0: + threading.Thread(target=do_workflow, args=( + video_clip.full_path, + video_clip.danmaku_clips[0].full_path, + *[clip.full_path for clip in video_clip.danmaku_clips[1:]] + )).start() return jsonify(workflow.to_dict())