marcocosta10000
6b3b6541a7
Initial project setup including the main agent script, configuration files, profile JSON state, systemd service unit, startup script, deployment documentation, and Python dependencies. Includes .env, venv/, and __pycache__/ which should likely be excluded via .gitignore to avoid committing secrets and artifacts.
180 lines
5.4 KiB
Python
180 lines
5.4 KiB
Python
"""
|
|
Matplotlib GUI progress bar decorator for iterators.
|
|
|
|
Usage:
|
|
>>> from tqdm.gui import trange, tqdm
|
|
>>> for i in trange(10):
|
|
... ...
|
|
"""
|
|
# future division is important to divide integers and get as
|
|
# a result precise floating numbers (instead of truncated int)
|
|
import re
|
|
from warnings import warn
|
|
|
|
# to inherit from the tqdm class
|
|
from .std import TqdmExperimentalWarning
|
|
from .std import tqdm as std_tqdm
|
|
|
|
# import compatibility functions and utilities
|
|
|
|
__author__ = {"github.com/": ["casperdcl", "lrq3000"]}
|
|
__all__ = ['tqdm_gui', 'tgrange', 'tqdm', 'trange']
|
|
|
|
|
|
class tqdm_gui(std_tqdm): # pragma: no cover
|
|
"""Experimental Matplotlib GUI version of tqdm!"""
|
|
# TODO: @classmethod: write() on GUI?
|
|
def __init__(self, *args, **kwargs):
|
|
from collections import deque
|
|
|
|
import matplotlib as mpl
|
|
import matplotlib.pyplot as plt
|
|
kwargs = kwargs.copy()
|
|
kwargs['gui'] = True
|
|
colour = kwargs.pop('colour', 'g')
|
|
super().__init__(*args, **kwargs)
|
|
|
|
if self.disable:
|
|
return
|
|
|
|
warn("GUI is experimental/alpha", TqdmExperimentalWarning, stacklevel=2)
|
|
self.mpl = mpl
|
|
self.plt = plt
|
|
|
|
# Remember if external environment uses toolbars
|
|
self.toolbar = self.mpl.rcParams['toolbar']
|
|
self.mpl.rcParams['toolbar'] = 'None'
|
|
|
|
self.mininterval = max(self.mininterval, 0.5)
|
|
self.fig, ax = plt.subplots(figsize=(9, 2.2))
|
|
# self.fig.subplots_adjust(bottom=0.2)
|
|
total = self.__len__() # avoids TypeError on None #971
|
|
if total is not None:
|
|
self.xdata = []
|
|
self.ydata = []
|
|
self.zdata = []
|
|
else:
|
|
self.xdata = deque([])
|
|
self.ydata = deque([])
|
|
self.zdata = deque([])
|
|
self.line1, = ax.plot(self.xdata, self.ydata, color='b')
|
|
self.line2, = ax.plot(self.xdata, self.zdata, color='k')
|
|
ax.set_ylim(0, 0.001)
|
|
if total is not None:
|
|
ax.set_xlim(0, 100)
|
|
ax.set_xlabel("percent")
|
|
self.fig.legend((self.line1, self.line2), ("cur", "est"),
|
|
loc='center right')
|
|
# progress bar
|
|
self.hspan = plt.axhspan(0, 0.001, xmin=0, xmax=0, color=colour)
|
|
else:
|
|
# ax.set_xlim(-60, 0)
|
|
ax.set_xlim(0, 60)
|
|
ax.invert_xaxis()
|
|
ax.set_xlabel("seconds")
|
|
ax.legend(("cur", "est"), loc='lower left')
|
|
ax.grid()
|
|
# ax.set_xlabel('seconds')
|
|
ax.set_ylabel((self.unit if self.unit else "it") + "/s")
|
|
if self.unit_scale:
|
|
plt.ticklabel_format(style='sci', axis='y', scilimits=(0, 0))
|
|
ax.yaxis.get_offset_text().set_x(-0.15)
|
|
|
|
# Remember if external environment is interactive
|
|
self.wasion = plt.isinteractive()
|
|
plt.ion()
|
|
self.ax = ax
|
|
|
|
def close(self):
|
|
if self.disable:
|
|
return
|
|
|
|
self.disable = True
|
|
|
|
with self.get_lock():
|
|
self._instances.remove(self)
|
|
|
|
# Restore toolbars
|
|
self.mpl.rcParams['toolbar'] = self.toolbar
|
|
# Return to non-interactive mode
|
|
if not self.wasion:
|
|
self.plt.ioff()
|
|
if self.leave:
|
|
self.display()
|
|
else:
|
|
self.plt.close(self.fig)
|
|
|
|
def clear(self, *_, **__):
|
|
pass
|
|
|
|
def display(self, *_, **__):
|
|
n = self.n
|
|
cur_t = self._time()
|
|
elapsed = cur_t - self.start_t
|
|
delta_it = n - self.last_print_n
|
|
delta_t = cur_t - self.last_print_t
|
|
|
|
# Inline due to multiple calls
|
|
total = self.total
|
|
xdata = self.xdata
|
|
ydata = self.ydata
|
|
zdata = self.zdata
|
|
ax = self.ax
|
|
line1 = self.line1
|
|
line2 = self.line2
|
|
hspan = getattr(self, 'hspan', None)
|
|
# instantaneous rate
|
|
y = delta_it / delta_t
|
|
# overall rate
|
|
z = n / elapsed
|
|
# update line data
|
|
xdata.append(n * 100.0 / total if total else cur_t)
|
|
ydata.append(y)
|
|
zdata.append(z)
|
|
|
|
# Discard old values
|
|
# xmin, xmax = ax.get_xlim()
|
|
# if (not total) and elapsed > xmin * 1.1:
|
|
if (not total) and elapsed > 66:
|
|
xdata.popleft()
|
|
ydata.popleft()
|
|
zdata.popleft()
|
|
|
|
ymin, ymax = ax.get_ylim()
|
|
if y > ymax or z > ymax:
|
|
ymax = 1.1 * y
|
|
ax.set_ylim(ymin, ymax)
|
|
ax.figure.canvas.draw()
|
|
|
|
if total:
|
|
line1.set_data(xdata, ydata)
|
|
line2.set_data(xdata, zdata)
|
|
if hspan:
|
|
hspan.set_xy((0, ymin))
|
|
hspan.set_height(ymax - ymin)
|
|
hspan.set_width(n / total)
|
|
else:
|
|
t_ago = [cur_t - i for i in xdata]
|
|
line1.set_data(t_ago, ydata)
|
|
line2.set_data(t_ago, zdata)
|
|
|
|
d = self.format_dict
|
|
# remove {bar}
|
|
d['bar_format'] = (d['bar_format'] or "{l_bar}<bar/>{r_bar}").replace(
|
|
"{bar}", "<bar/>")
|
|
msg = self.format_meter(**d)
|
|
if '<bar/>' in msg:
|
|
msg = "".join(re.split(r'\|?<bar/>\|?', msg, maxsplit=1))
|
|
ax.set_title(msg, fontname="DejaVu Sans Mono", fontsize=11)
|
|
self.plt.pause(1e-9)
|
|
|
|
|
|
def tgrange(*args, **kwargs):
|
|
"""Shortcut for `tqdm.gui.tqdm(range(*args), **kwargs)`."""
|
|
return tqdm_gui(range(*args), **kwargs)
|
|
|
|
|
|
# Aliases
|
|
tqdm = tqdm_gui
|
|
trange = tgrange
|