(capsys)
| 97 | |
| 98 | |
| 99 | def test_with_cache(capsys): |
| 100 | cachey = pytest.importorskip("cachey") |
| 101 | from dask.cache import Cache |
| 102 | |
| 103 | c = cachey.Cache(10000) |
| 104 | cc = Cache(c) |
| 105 | |
| 106 | with cc: |
| 107 | with ProgressBar(): |
| 108 | assert get_threaded({"x": (mul, 1, 2)}, "x") == 2 |
| 109 | check_bar_completed(capsys) |
| 110 | assert c.data["x"] == 2 |
| 111 | |
| 112 | with cc: |
| 113 | with ProgressBar(): |
| 114 | assert get_threaded({"x": (mul, 1, 2), "y": (mul, "x", 3)}, "y") == 6 |
| 115 | check_bar_completed(capsys) |
| 116 | |
| 117 | |
| 118 | def test_with_alias(capsys): |
nothing calls this directly
no test coverage detected
searching dependent graphs…