comment out sys._current_frames()[thread_id] call

Author: graingert

distributed/profile.py

@@ -29,7 +29,6 @@
 import bisect
 import dis
 import linecache
-import sys
 import threading
 import weakref
 from collections import defaultdict, deque
@@ -295,12 +294,12 @@ def _watch(
             log.append((time(), recent))
             recent = create()
             last = time()
-        try:
-            frame = sys._current_frames()[thread_id]
-        except KeyError:
-            return
+        # try:
+        #     frame = sys._current_frames()[thread_id]
+        # except KeyError:
+        #     return
 
-        process(frame, None, recent, omit=omit)
+        # process(frame, None, recent, omit=omit)
         stop_event.wait(interval)
 
 

distributed/tests/test_spill.py

@@ -342,9 +342,9 @@ def _print_chain(o_wr):
 )
 @pytest.mark.parametrize("size", [60, 110])
 def test_weakref_cache(tmpdir, cls, expect_cached, size, attempt):
-    from distributed.profile import shutdown_profile_threads
+    # from distributed.profile import shutdown_profile_threads
 
-    shutdown_profile_threads()
+    # shutdown_profile_threads()
 
     gc.disable()
     try: