|
|
|
@ -111,7 +111,7 @@ async def video_worker():
|
|
|
|
|
async def _video_worker():
|
|
|
|
|
while True:
|
|
|
|
|
video_json, start_time, first_try_live = await video_queue.get()
|
|
|
|
|
is_late = first_try_live or (Decimal(time.time()) - Decimal(start_time)) < 5
|
|
|
|
|
is_late = first_try_live or (Decimal(time.time()) - Decimal(start_time)) > 5
|
|
|
|
|
command = ['ffmpeg']
|
|
|
|
|
tempdir_obj = tempfile.TemporaryDirectory(dir='.')
|
|
|
|
|
try:
|
|
|
|
|