github/gallery-dl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

explicitly flush all writes to stdout (#2529)

Browse Source
This commit is contained in:
Mike Fährmann
2022-05-17 13:26:53 +02:00
parent a96f9d29b5
commit eeef9ccdc1
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
gallery_dl/output.py
View File

@@ -265,14 +265,12 @@ class NullOutput():
class PipeOutput(NullOutput): class PipeOutput(NullOutput):
def skip(self, path): def skip(self, path):
stdout = sys.stdout sys.stdout.write(CHAR_SKIP + path + "\n")
stdout.write(CHAR_SKIP + path + "\n") sys.stdout.flush()
stdout.flush()
def success(self, path, tries): def success(self, path, tries):
stdout = sys.stdout sys.stdout.write(path + "\n")
stdout.write(path + "\n") sys.stdout.flush()
stdout.flush()
class TerminalOutput(NullOutput): class TerminalOutput(NullOutput):
@@ -288,15 +286,16 @@ class TerminalOutput(NullOutput):
self.shorten = util.identity self.shorten = util.identity
def start(self, path): def start(self, path):
stdout = sys.stdout sys.stdout.write(self.shorten(" " + path))
stdout.write(self.shorten(" " + path)) sys.stdout.flush()
stdout.flush()
def skip(self, path): def skip(self, path):
sys.stdout.write(self.shorten(CHAR_SKIP + path) + "\n") sys.stdout.write(self.shorten(CHAR_SKIP + path) + "\n")
sys.stdout.flush()
def success(self, path, tries): def success(self, path, tries):
sys.stdout.write("\r" + self.shorten(CHAR_SUCCESS + path) + "\n") sys.stdout.write("\r" + self.shorten(CHAR_SUCCESS + path) + "\n")
sys.stdout.flush()
def progress(self, bytes_total, bytes_downloaded, bytes_per_second): def progress(self, bytes_total, bytes_downloaded, bytes_per_second):
bdl = util.format_value(bytes_downloaded) bdl = util.format_value(bytes_downloaded)
@@ -320,15 +319,16 @@ class ColorOutput(TerminalOutput):
colors.get("success", "1;32")) colors.get("success", "1;32"))
def start(self, path): def start(self, path):
stdout = sys.stdout sys.stdout.write(self.shorten(path))
stdout.write(self.shorten(path)) sys.stdout.flush()
stdout.flush()
def skip(self, path): def skip(self, path):
sys.stdout.write(self.color_skip + self.shorten(path) + "\033[0m\n") sys.stdout.write(self.color_skip + self.shorten(path) + "\033[0m\n")
sys.stdout.flush()
def success(self, path, tries): def success(self, path, tries):
sys.stdout.write(self.color_success + self.shorten(path) + "\033[0m\n") sys.stdout.write(self.color_success + self.shorten(path) + "\033[0m\n")
sys.stdout.flush()
class EAWCache(dict): class EAWCache(dict):