FM / tqdm

/usr/local/lib/python3.6/site-packages/tqdm/

/usr/local/lib/python3.6/site-packages/tqdm

Name	Size	Mode	Actions
contrib/	-	0755	rm
__pycache__/	-	0755	rm
asyncio.py	2789	0644	edit dl rm
auto.py	1106	0644	edit dl rm
autonotebook.py	956	0644	edit dl rm
cli.py	10871	0644	edit dl rm
completion.sh	946	0755	edit dl rm
dask.py	1377	0644	edit dl rm
gui.py	5943	0644	edit dl rm
keras.py	4409	0644	edit dl rm
notebook.py	11317	0644	edit dl rm
rich.py	5152	0644	edit dl rm
std.py	58341	0644	edit dl rm
tk.py	6948	0644	edit dl rm
tqdm.1	7997	0644	edit dl rm
utils.py	9803	0644	edit dl rm
version.py	333	0644	edit dl rm
_dist_ver.py	23	0644	edit dl rm
_main.py	283	0644	edit dl rm
_monitor.py	3699	0644	edit dl rm
_tqdm.py	283	0644	edit dl rm
_tqdm_gui.py	287	0644	edit dl rm
_tqdm_notebook.py	307	0644	edit dl rm
_tqdm_pandas.py	888	0644	edit dl rm
_utils.py	596	0644	edit dl rm
__init__.py	1639	0644	edit dl rm
__main__.py	30	0644	edit dl rm

Edit: /usr/local/lib/python3.6/site-packages/tqdm/dask.py (1377B)

from __future__ import absolute_import

from functools import partial

from dask.callbacks import Callback

from .auto import tqdm as tqdm_auto

__author__ = {"github.com/": ["casperdcl"]}
__all__ = ['TqdmCallback']

class TqdmCallback(Callback):
    """Dask callback for task progress."""
    def __init__(self, start=None, pretask=None, tqdm_class=tqdm_auto,
                 **tqdm_kwargs):
        """
        Parameters
        ----------
        tqdm_class  : optional
            `tqdm` class to use for bars [default: `tqdm.auto.tqdm`].
        tqdm_kwargs  : optional
            Any other arguments used for all bars.
        """
        super(TqdmCallback, self).__init__(start=start, pretask=pretask)
        if tqdm_kwargs:
            tqdm_class = partial(tqdm_class, **tqdm_kwargs)
        self.tqdm_class = tqdm_class

def _start_state(self, _, state):
        self.pbar = self.tqdm_class(total=sum(
            len(state[k]) for k in ['ready', 'waiting', 'running', 'finished']))

def _posttask(self, *_, **__):
        self.pbar.update()

def _finish(self, *_, **__):
        self.pbar.close()

def display(self):
        """Displays in the current cell in Notebooks."""
        container = getattr(self.bar, 'container', None)
        if container is None:
            return
        from .notebook import display
        display(container)

from __future__ import absolute_import from functools import partial from dask.callbacks import Callback from .auto import tqdm as tqdm_auto __author__ = {"github.com/": ["casperdcl"]} __all__ = ['TqdmCallback'] class TqdmCallback(Callback): """Dask callback for task progress.""" def __init__(self, start=None, pretask=None, tqdm_class=tqdm_auto, **tqdm_kwargs): """ Parameters ---------- tqdm_class : optional `tqdm` class to use for bars [default: `tqdm.auto.tqdm`]. tqdm_kwargs : optional Any other arguments used for all bars. """ super(TqdmCallback, self).__init__(start=start, pretask=pretask) if tqdm_kwargs: tqdm_class = partial(tqdm_class, **tqdm_kwargs) self.tqdm_class = tqdm_class def _start_state(self, _, state): self.pbar = self.tqdm_class(total=sum( len(state[k]) for k in ['ready', 'waiting', 'running', 'finished'])) def _posttask(self, *_, **__): self.pbar.update() def _finish(self, *_, **__): self.pbar.close() def display(self): """Displays in the current cell in Notebooks.""" container = getattr(self.bar, 'container', None) if container is None: return from .notebook import display display(container)