From e786f39cc2654d61bfbeaa52f3e2fff9b02151c1 Mon Sep 17 00:00:00 2001 From: Gabe Joseph Date: Mon, 21 Jun 2021 18:41:34 -0600 Subject: [PATCH] Debug flaky test_robust_to_bad_sizeof_estimates --- distributed/tests/test_worker.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index ba4de5199d..1dad7ebbbd 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -1111,6 +1111,7 @@ async def test_robust_to_bad_sizeof_estimates(c, s, a): np = pytest.importorskip("numpy") memory = psutil.Process().memory_info().rss a.memory_limit = memory / 0.7 + 400e6 + print("memory limit:", format_bytes(a.memory_limit)) class BadAccounting: def __init__(self, data): @@ -1128,6 +1129,12 @@ def f(n): start = time() while not a.data.disk: + print( + "RSS:", + format_bytes(psutil.Process().memory_info().rss), + "disk:", + list(a.data.disk), + ) await asyncio.sleep(0.1) assert time() < start + 5