Cutlery/calibre
1
0
Fork 0
mirror of https://github.com/kovidgoyal/calibre.git synced 2025-07-09 03:04:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

Suppress BrokenPipeError in logging

Browse Source 
https://bugzilla.redhat.com/show_bug.cgi?id=1903583 sports the following traceback:
Traceback (most recent call last):
  File "/usr/bin/ebook-convert", line 20, in <module>
    sys.exit(main())
  File "/usr/lib64/calibre/calibre/ebooks/conversion/cli.py", line 401, in main
    plumber.run()
  File "/usr/lib64/calibre/calibre/ebooks/conversion/plumber.py", line 1135, in run
    pr(0., _('Running transforms on e-book...'))
  File "/usr/lib64/calibre/calibre/ebooks/conversion/plumber.py", line 67, in __call__
    self.global_reporter(global_frac, msg)
  File "/usr/lib64/calibre/calibre/ebooks/conversion/cli.py", line 288, in __call__
    self.log('%d%% %s'%(percent, msg))
  File "/usr/lib64/calibre/calibre/utils/logging.py", line 179, in __call__
    self.info(*args, **kwargs)
  File "/usr/lib64/calibre/calibre/utils/logging.py", line 171, in print_with_flush
    self.flush()
  File "/usr/lib64/calibre/calibre/utils/logging.py", line 191, in flush
    o.flush()
  File "/usr/lib64/calibre/calibre/utils/logging.py", line 53, in flush
    self.stream.flush()
BrokenPipeError: [Errno 32] Datenübergabe unterbrochen (broken pipe)

If logging fails because somebody closed the output pipe, this is not an error.
Let's just ignore this this silently.

I removed the two .flush() implementations because those two classes inherit
from Stream.
This commit is contained in:
Zbigniew Jędrzejewski-Szmek 2021-09-30 09:05:03 +02:00
parent 52c55cc42e
commit fa8bbfda15
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/calibre/utils/logging.py
View File

@ -31,7 +31,11 @@ class Stream(object):
self._prints(text, end='') self._prints(text, end='')
def flush(self): def flush(self):
self.stream.flush() try:
self.stream.flush()
except BrokenPipeError:
# Don't make any fuss if we were logging to a pipe and it got closed
pass
def prints(self, level, *args, **kwargs): def prints(self, level, *args, **kwargs):
self._prints(*args, **kwargs) self._prints(*args, **kwargs)
@ -61,9 +65,6 @@ class ANSIStream(Stream):
with ColoredStream(self.stream, self.color[level]): with ColoredStream(self.stream, self.color[level]):
self._prints(*args, **kwargs) self._prints(*args, **kwargs)
def flush(self):
self.stream.flush()
class FileStream(Stream): class FileStream(Stream):
@ -94,9 +95,6 @@ class HTMLStream(Stream):
self._prints(*args, **kwargs) self._prints(*args, **kwargs)
self._prints(self.normal, end='') self._prints(self.normal, end='')
def flush(self):
self.stream.flush()
class UnicodeHTMLStream(HTMLStream): class UnicodeHTMLStream(HTMLStream):