q792602257/my-video-workflow
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

在直播的时候就不上传了

Browse Source
This commit is contained in:
Jerry Yan 2022-08-04 09:12:27 +08:00
parent c9ceaeca67
commit 95008dc65b
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
controller/api/bilirecorder_blueprint.py
View File

@ -13,7 +13,7 @@ from model import db
from model.DanmakuClip import DanmakuClip from model.DanmakuClip import DanmakuClip
from model.VideoClip import VideoClip from model.VideoClip import VideoClip
from model.Workflow import Workflow from model.Workflow import Workflow
from workflow.bilibili import IS_LIVING, INSTANCE as bilibili_instance from workflow.bilibili import IS_LIVING, IS_UPLOADING, INSTANCE as bilibili_instance
from workflow.bilibili import VideoPart from workflow.bilibili import VideoPart
from workflow.danmaku import get_file_start from workflow.danmaku import get_file_start
from workflow.video import get_video_real_duration, duration_str_to_float from workflow.video import get_video_real_duration, duration_str_to_float
@ -61,6 +61,8 @@ def auto_submit_task():
print("[-]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path, "; No Danmaku") print("[-]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path, "; No Danmaku")
if _future is not None: if _future is not None:
def _on_upload_finish(_f: "Future"): def _on_upload_finish(_f: "Future"):
if IS_UPLOADING.is_set() or IS_LIVING.is_set():
return
bilibili_instance.finish_upload( bilibili_instance.finish_upload(
title=video_title, title=video_title,
desc=VIDEO_DESC, desc=VIDEO_DESC,

5
workflow/bilibili.py
View File

@ -56,9 +56,8 @@ class Bilibili:
:type no_reprint: int :type no_reprint: int
""" """
self.pre_upload(parts) self.pre_upload(parts)
if not IS_LIVING.is_set(): self.finish_upload(title, tid, tag, desc, source, cover, no_reprint)
self.finish_upload(title, tid, tag, desc, source, cover, no_reprint) self.clear()
self.clear()
def pre_upload(self, parts: "VideoPart", max_retry=5): def pre_upload(self, parts: "VideoPart", max_retry=5):
""" """