|
|
|
@ -237,7 +237,7 @@ async def _video_worker():
|
|
|
|
|
proc = await asyncio.create_subprocess_exec(*(await construct_command()), stdin=asyncio.subprocess.PIPE, stdout=log_file, stderr=log_file)
|
|
|
|
|
except BaseException:
|
|
|
|
|
tempdir_obj.cleanup()
|
|
|
|
|
raise
|
|
|
|
|
raise Exception(f'This is a hack to retrieve the video id ({video_json["id"]}), the actual exception should be above')
|
|
|
|
|
upload_queue.put_nowait((tempdir_obj, video_json))
|
|
|
|
|
video_queue.task_done()
|
|
|
|
|
|
|
|
|
|