etc/yt-dlp
0
0
Fork 0
mirror of https://github.com/yt-dlp/yt-dlp.git synced 2024-11-26 02:55:17 +00:00
Code Issues Projects Releases Wiki Activity

Add only_once param for write_debug

Browse source
This commit is contained in:
pukkandan 2021-07-21 18:06:34 +05:30
parent 352d63fdb5
commit b35496d825
No known key found for this signature in database
GPG key ID: 0F00D95A001F4698
1 changed files with 13 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
yt_dlp/YoutubeDL.py
View file

@ -450,7 +450,7 @@ class YoutubeDL(object):
params = None params = None
_ies = [] _ies = []
_pps = {'pre_process': [], 'before_dl': [], 'after_move': [], 'post_process': []} _pps = {'pre_process': [], 'before_dl': [], 'after_move': [], 'post_process': []}
_reported_warnings = set() _printed_messages = set()
_first_webpage_request = True _first_webpage_request = True
_download_retcode = None _download_retcode = None
_num_downloads = None _num_downloads = None
@ -465,7 +465,7 @@ def __init__(self, params=None, auto_init=True):
self._ies = [] self._ies = []
self._ies_instances = {} self._ies_instances = {}
self._pps = {'pre_process': [], 'before_dl': [], 'after_move': [], 'post_process': []} self._pps = {'pre_process': [], 'before_dl': [], 'after_move': [], 'post_process': []}
self._reported_warnings = set() self._printed_messages = set()
self._first_webpage_request = True self._first_webpage_request = True
self._post_hooks = [] self._post_hooks = []
self._progress_hooks = [] self._progress_hooks = []
@ -660,8 +660,12 @@ def _bidi_workaround(self, message):
for _ in range(line_count)) for _ in range(line_count))
return res[:-len('\n')] return res[:-len('\n')]
def _write_string(self, s, out=None): def _write_string(self, message, out=None, only_once=False):
write_string(s, out=out, encoding=self.params.get('encoding')) if only_once:
if message in self._printed_messages:
return
self._printed_messages.add(message)
write_string(message, out=out, encoding=self.params.get('encoding'))
def to_stdout(self, message, skip_eol=False, quiet=False): def to_stdout(self, message, skip_eol=False, quiet=False):
"""Print message to stdout""" """Print message to stdout"""
@ -672,13 +676,13 @@ def to_stdout(self, message, skip_eol=False, quiet=False):
'%s%s' % (self._bidi_workaround(message), ('' if skip_eol else '\n')), '%s%s' % (self._bidi_workaround(message), ('' if skip_eol else '\n')),
self._err_file if quiet else self._screen_file) self._err_file if quiet else self._screen_file)
def to_stderr(self, message): def to_stderr(self, message, only_once=False):
"""Print message to stderr""" """Print message to stderr"""
assert isinstance(message, compat_str) assert isinstance(message, compat_str)
if self.params.get('logger'): if self.params.get('logger'):
self.params['logger'].error(message) self.params['logger'].error(message)
else: else:
self._write_string('%s\n' % self._bidi_workaround(message), self._err_file) self._write_string('%s\n' % self._bidi_workaround(message), self._err_file, only_once=only_once)
def to_console_title(self, message): def to_console_title(self, message):
if not self.params.get('consoletitle', False): if not self.params.get('consoletitle', False):
@ -760,10 +764,6 @@ def report_warning(self, message, only_once=False):
Print the message to stderr, it will be prefixed with 'WARNING:' Print the message to stderr, it will be prefixed with 'WARNING:'
If stderr is a tty file the 'WARNING:' will be colored If stderr is a tty file the 'WARNING:' will be colored
''' '''
if only_once:
if message in self._reported_warnings:
return
self._reported_warnings.add(message)
if self.params.get('logger') is not None: if self.params.get('logger') is not None:
self.params['logger'].warning(message) self.params['logger'].warning(message)
else: else:
@ -774,7 +774,7 @@ def report_warning(self, message, only_once=False):
else: else:
_msg_header = 'WARNING:' _msg_header = 'WARNING:'
warning_message = '%s %s' % (_msg_header, message) warning_message = '%s %s' % (_msg_header, message)
self.to_stderr(warning_message) self.to_stderr(warning_message, only_once)
def report_error(self, message, tb=None): def report_error(self, message, tb=None):
''' '''
@ -788,7 +788,7 @@ def report_error(self, message, tb=None):
error_message = '%s %s' % (_msg_header, message) error_message = '%s %s' % (_msg_header, message)
self.trouble(error_message, tb) self.trouble(error_message, tb)
def write_debug(self, message): def write_debug(self, message, only_once=False):
'''Log debug message or Print message to stderr''' '''Log debug message or Print message to stderr'''
if not self.params.get('verbose', False): if not self.params.get('verbose', False):
return return
@ -796,7 +796,7 @@ def write_debug(self, message):
if self.params.get('logger'): if self.params.get('logger'):
self.params['logger'].debug(message) self.params['logger'].debug(message)
else: else:
self._write_string('%s\n' % message) self.to_stderr(message, only_once)
def report_file_already_downloaded(self, file_name): def report_file_already_downloaded(self, file_name):
"""Report file has already been fully downloaded.""" """Report file has already been fully downloaded."""