diff --git a/controller/api/bilirecorder_blueprint.py b/controller/api/bilirecorder_blueprint.py index 824616e..beb1385 100644 --- a/controller/api/bilirecorder_blueprint.py +++ b/controller/api/bilirecorder_blueprint.py @@ -32,9 +32,11 @@ def auto_submit_task(): if len(bili_record_workflow_item.video_clips) == 0: print("[!]Auto Submit Fail: No Video Clips") return + _started = False for video_clip in bili_record_workflow_item.video_clips: if len(video_clip.danmaku_clips) > 0: print("[+]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path) + _started = True threading.Thread(target=do_workflow, args=( video_clip.full_path, video_clip.danmaku_clips[0].full_path, @@ -42,7 +44,8 @@ def auto_submit_task(): )).start() else: print("[-]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path, "; No Danmaku") - clear_item() + if _started: + clear_item() def clear_item(): @@ -53,13 +56,6 @@ def clear_item(): bili_record_workflow_item.editing = True -def reload_item(): - global bili_record_workflow_item - if bili_record_workflow_item is None: - return - bili_record_workflow_item = Workflow.query.get(bili_record_workflow_item.id) - - def commit_item(): global bili_record_workflow_item if bili_record_workflow_item is None: @@ -188,7 +184,6 @@ def bilirecorder_event(): item.video_clips.append(video_clip) commit_item() collect_danmaku_files(item) - reload_item() auto_submit_task() return jsonify(item.to_dict()) commit_item()