You've already forked my-video-workflow
支持控制自动投递
This commit is contained in:
@ -7,7 +7,7 @@ from typing import Optional
|
||||
from flask import Blueprint, jsonify, request, current_app
|
||||
|
||||
from config import BILILIVE_RECORDER_DIRECTORY, VIDEO_TITLE, XIGUALIVE_RECORDER_DIRECTORY, VIDEO_DESC, \
|
||||
VIDEO_TAGS, VIDEO_TID
|
||||
VIDEO_TAGS, VIDEO_TID, VIDEO_ENABLED
|
||||
from exception.danmaku import DanmakuException
|
||||
from model import db
|
||||
from model.DanmakuClip import DanmakuClip
|
||||
@ -49,14 +49,17 @@ def auto_submit_task():
|
||||
*[clip.full_path for clip in video_clip.danmaku_clips[1:]]
|
||||
)
|
||||
clear_item()
|
||||
def _encode_finish_callback(_f: "Future"):
|
||||
_result = _f.result()
|
||||
if _result:
|
||||
# start uploading
|
||||
bilibili_instance.pre_upload(
|
||||
parts=[VideoPart(os.path.join(_item['base_path'], _item['file']), _item['file']) for _item in
|
||||
_result])
|
||||
_future.add_done_callback(_encode_finish_callback)
|
||||
if VIDEO_ENABLED:
|
||||
def _encode_finish_callback(_f: "Future"):
|
||||
_result = _f.result()
|
||||
if _result:
|
||||
# start uploading
|
||||
bilibili_instance.pre_upload(
|
||||
parts=[VideoPart(os.path.join(_item['base_path'], _item['file']), _item['file']) for _item
|
||||
in
|
||||
_result])
|
||||
|
||||
_future.add_done_callback(_encode_finish_callback)
|
||||
else:
|
||||
print("[-]Workflow:", bili_record_workflow_item.id, "; Video:", video_clip.full_path, "; No Danmaku")
|
||||
if _future is not None:
|
||||
|
Reference in New Issue
Block a user