github-actions[bot]
commented
21 hours ago Open DuskXi opened 21 hours ago
github-actions[bot]
commented
21 hours ago 
willmcgugan
commented
21 hours ago Without code, I can't say what you are doing wrong. Please share a short piece of code that demonstrates the problem.
DuskXi
commented
20 hours ago Thank you very much for your reply. Below is the test I did, and the comments following each function are the console output status I intercepted
import threading
import time
from rich.live import Live
from rich.progress import Progress
from rich.console import Console
from rich import print as rprint
def test_progress_1():
with Progress() as progress:
task = progress.add_task("[Red]Running", total=100)
for i in range(100):
for j in range(100):
print(f"{j}", end="")
time.sleep(0.002)
progress.update(task, advance=1)
time.sleep(0.1)
# running:
# python3 test.py
# [Red]Running ━━━━━━━━━━━━━━━━━╸━━━━━━━━━━━━━━━━━━━━━━ 44% 0:00:18
# after exit:
# 0123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
# ......
# [Red]Running ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 100% 0:00:00
def test_progress_2():
def print_thread():
for j in range(100):
print(f"{j}", end="")
time.sleep(0.002)
with Progress() as progress:
task = progress.add_task("[Red]Running", total=100)
for i in range(100):
thread = threading.Thread(target=print_thread)
thread.start()
while thread.is_alive():
time.sleep(0.1)
thread.join()
progress.update(task, advance=1)
time.sleep(0.1)
# running:
# python3 test.py
# [Red]Running ━━━━━━━━━━━━━━━━━╸━━━━━━━━━━━━━━━━━━━━━━ 44% 0:00:18
# after exit:
# 0123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
# ......
# [Red]Running ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 100% 0:00:00
def test_progress_3():
with Progress() as progress:
task = progress.add_task("[Red]Running", total=100)
for i in range(100):
for j in range(100):
rprint(f"{j}", end="")
time.sleep(0.002)
progress.update(task, advance=1)
time.sleep(0.1)
# running:
# python3 test.py
# 68[Red]Running ━━━━━╺━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 13% 0:00:32
# after exit:
# [Red]Running ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 100% 0:00:00
def test_progress_4():
console = Console()
with Progress(console=console) as progress:
task = progress.add_task("[Red]Running", total=100)
for i in range(100):
for j in range(100):
console.print(f"{j}", end="")
time.sleep(0.002)
progress.update(task, advance=1)
time.sleep(0.1)
# running:
# python3 test.py
# 68[Red]Running ━━━━━╺━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 13% 0:00:32
# after exit:
# [Red]Running ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 100% 0:00:00
def test_progress_5():
console = Console()
progress = Progress(console=console)
task = progress.add_task("Downloading", total=100)
with Live(console=console, auto_refresh=False, transient=True) as live:
for i in range(100):
for j in range(100):
console.print(f"{j}", end="")
time.sleep(0.002)
progress.update(task, advance=1)
live.update(progress)
live.refresh()
time.sleep(0.1)
# running:
# python3 test.py
# 68[Red]Running ━━━━━╺━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 13% 0:00:32
# after exit:
# [Red]Running ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 100% 0:00:00
def test_progress_6():
console = Console()
progress = Progress(console=console)
task = progress.add_task("Downloading", total=100)
with Live(console=console, auto_refresh=False, transient=True) as live:
for i in range(100):
for j in range(100):
rprint(f"{j}", end="")
time.sleep(0.002)
progress.update(task, advance=1)
live.update(progress)
live.refresh()
time.sleep(0.1)
# running:
# python3 test.py
# 0123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899Downloading ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 1% -:--:--01234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636
# Downloading ━━━━━━━╸━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 19% 0:00:2901234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
# exit:
# 0123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899Downloading ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 1% -:--:--01234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636
Without code, I can't say what you are doing wrong. Please share a short piece of code that demonstrates the problem.
arnimarj
commented
17 hours ago I've hit a similar use case. I was running concurrent downloads and wanted a progress meter for each download, along with a log output when each (potentially failed) download finished.
Since both rich and the logging framework were using stdout, the outputs would sometimes mix. I solved it by guarding each relevant logging call with with progress.live._lock: ... for my instance of rich.progress.Progress.
But that's an undocumented feature I guess.
Describe the bug
I hope to use rich.progress.Progress and real-time streaming output without line breaks at the same time. At the same time, I hope that the text will not be modified by any subsequent operations after the line break appears. I tried many ways but none of them worked. I tried the following methods
Using Progress() + print(text, end="") will make it invisible during the run until the process ends. This completely loses the effect of streaming
Using Progress() [main thread] + print(text, end="") [child thread] will cause end="" to fail, and each print will wrap, which also seriously destroys the effect and format of streaming
Using Progress() + rpint(text, end="") or console.print(text, end="") will cause the text in the same line to overwite the previously printed text.
Using Progress() + Live(auto_refresh=False) + rpint(text, end="") Only the first line of streaming works, and each subsequent refresh will cause the previously output content to disappear. Enabling the transient parameter is also useless
Platform
Windows
Click to expand
What platform (Win/Linux/Mac) are you running on? What terminal software are you using? I may ask you to copy and paste the output of the following commands. It may save some time if you do it now. If you're using Rich in a terminal: ``` python -m rich.diagnose pip freeze | grep rich ``` If you're using Rich in a Jupyter Notebook, run the following snippet in a cell and paste the output in your bug report. ```python from rich.diagnose import report report() ``` ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────rich==13.9.2