Upstream/yt-dlp
1
0
Fork 0
mirror of https://github.com/yt-dlp/yt-dlp.git synced 2024-07-06 12:16:01 +02:00
Code Issues Packages Projects Releases Wiki Activity

Bugfix for 23326151c4

Browse Source
This commit is contained in:
pukkandan 2022-05-20 20:49:30 +05:30
parent 854b0d325e
commit 666c36d58d
No known key found for this signature in database
GPG Key ID: 7EEE9E1E817D0A39
2 changed files with 8 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
yt_dlp/downloader/common.py
View File

@ -18,8 +18,8 @@
decodeArgument, decodeArgument,
encodeFilename, encodeFilename,
error_to_compat_str, error_to_compat_str,
float_or_none,
format_bytes, format_bytes,
int_or_none,
sanitize_open, sanitize_open,
shell_quote, shell_quote,
timeconvert, timeconvert,
@ -406,9 +406,9 @@ def report_unable_to_resume(self):
def sleep_retry(self, retry_type, count): def sleep_retry(self, retry_type, count):
sleep_func = self.params.get('retry_sleep_functions', {}).get(retry_type) sleep_func = self.params.get('retry_sleep_functions', {}).get(retry_type)
delay = int_or_none(sleep_func(n=count - 1)) if sleep_func else None delay = float_or_none(sleep_func(n=count - 1)) if sleep_func else None
if delay: if delay:
self.__to_screen(f'Sleeping {delay} seconds ...') self.__to_screen(f'Sleeping {delay:.2f} seconds ...')
time.sleep(delay) time.sleep(delay)
return sleep_func is not None return sleep_func is not None

17
yt_dlp/downloader/fragment.py
View File

@ -165,18 +165,11 @@ def _prepare_frag_download(self, ctx):
total_frags_str = 'unknown (live)' total_frags_str = 'unknown (live)'
self.to_screen(f'[{self.FD_NAME}] Total fragments: {total_frags_str}') self.to_screen(f'[{self.FD_NAME}] Total fragments: {total_frags_str}')
self.report_destination(ctx['filename']) self.report_destination(ctx['filename'])
dl = HttpQuietDownloader( dl = HttpQuietDownloader(self.ydl, {
self.ydl, **self.params,
{ 'noprogress': True,
'continuedl': self.params.get('continuedl', True), 'test': False,
'quiet': self.params.get('quiet'), })
'noprogress': True,
'ratelimit': self.params.get('ratelimit'),
'retries': self.params.get('retries', 0),
'nopart': self.params.get('nopart', False),
'test': False,
}
)
tmpfilename = self.temp_name(ctx['filename']) tmpfilename = self.temp_name(ctx['filename'])
open_mode = 'wb' open_mode = 'wb'
resume_len = 0 resume_len = 0