From 668f3f1d38c27277448af6f5aa88741cd1d33f3b Mon Sep 17 00:00:00 2001 From: James Bourbeau Date: Wed, 9 Jun 2021 08:57:53 -0500 Subject: Remove tests for `process_time` and `thread_time` (#4895) --- distributed/tests/test_metrics.py | 46 ------------------------------- 1 file changed, 46 deletions(-) diff --git a/distributed/tests/test_metrics.py b/distributed/tests/test_metrics.py index 3a27e638..58c33266 100644 --- a/distributed/tests/test_metrics.py +++ b/distributed/tests/test_metrics.py @@ -1,9 +1,6 @@ -import sys -import threading import time from distributed import metrics -from distributed.utils_test import run_for def test_wall_clock(): @@ -18,46 +15,3 @@ def test_wall_clock(): assert any(lambda d: 0.0 < d < 0.0001 for d in deltas), deltas # Close to time.time() assert t - 0.5 < samples[0] < t + 0.5 - - -def test_process_time(): - start = metrics.process_time() - run_for(0.05) - dt = metrics.process_time() - start - assert 0.03 <= dt <= 0.2 - - # All threads counted - t = threading.Thread(target=run_for, args=(0.1,)) - start = metrics.process_time() - t.start() - t.join() - dt = metrics.process_time() - start - assert dt >= 0.05 - - # Sleep time not counted - start = metrics.process_time() - time.sleep(0.1) - dt = metrics.process_time() - start - assert dt <= 0.05 - - -def test_thread_time(): - start = metrics.thread_time() - run_for(0.05) - dt = metrics.thread_time() - start - assert 0.03 <= dt <= 0.2 - - # Sleep time not counted - start = metrics.thread_time() - time.sleep(0.1) - dt = metrics.thread_time() - start - assert dt <= 0.05 - - if sys.platform == "linux": - # Always per-thread on Linux - t = threading.Thread(target=run_for, args=(0.1,)) - start = metrics.thread_time() - t.start() - t.join() - dt = metrics.thread_time() - start - assert dt <= 0.05 -- 2.20.1