1
0
Fork 0
tqdm/tests/tests_dask.py
Daniel Baumann ee135df3b4
Adding upstream version 4.66.2.
Signed-off-by: Daniel Baumann <daniel@debian.org>
2025-02-05 19:14:23 +01:00

18 lines
467 B
Python

from time import sleep
from .tests_tqdm import importorskip, mark
pytestmark = mark.slow
def test_dask(capsys):
"""Test tqdm.dask.TqdmCallback"""
ProgressBar = importorskip('tqdm.dask').TqdmCallback
dask = importorskip('dask')
schedule = [dask.delayed(sleep)(i / 10) for i in range(5)]
with ProgressBar(desc="computing"):
dask.compute(schedule)
_, err = capsys.readouterr()
assert "computing: " in err
assert '5/5' in err