fix workflow info and redo func

This commit is contained in:
root 2022-04-23 05:49:33 +08:00
parent 9f6038d1f7
commit cdf46458be

View File

@ -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("/<int:workflow_id>")
@ -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())