Fixed typing in s3
This commit is contained in:
parent
7cf5a5137e
commit
aac8314837
1 changed files with 3 additions and 1 deletions
|
@ -3,6 +3,7 @@ Construct the S3 source.
|
||||||
|
|
||||||
Adds it to the ``available_sources`` with the name ``s3``
|
Adds it to the ``available_sources`` with the name ``s3``
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
import os
|
import os
|
||||||
from json import dump, load
|
from json import dump, load
|
||||||
|
@ -135,8 +136,9 @@ class S3Source(FileBasedSource):
|
||||||
asyncio.to_thread(self.minio.fget_object, self.bucket, entry.ident, video_dl_path)
|
asyncio.to_thread(self.minio.fget_object, self.bucket, entry.ident, video_dl_path)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
audio_dl_path: Optional[str]
|
||||||
if audio_path is not None:
|
if audio_path is not None:
|
||||||
audio_dl_path: Optional[str] = os.path.join(self.tmp_dir, audio_path)
|
audio_dl_path = os.path.join(self.tmp_dir, audio_path)
|
||||||
|
|
||||||
audio_dl_task: asyncio.Task[Any] = asyncio.create_task(
|
audio_dl_task: asyncio.Task[Any] = asyncio.create_task(
|
||||||
asyncio.to_thread(self.minio.fget_object, self.bucket, audio_path, audio_dl_path)
|
asyncio.to_thread(self.minio.fget_object, self.bucket, audio_path, audio_dl_path)
|
||||||
|
|
Loading…
Add table
Reference in a new issue