Remove cache in iscoroutinefunction to avoid holding on to refs (#5985)

dask · Mar 24, 2022 · 9d3064a · 9d3064a
1 parent 0e8f2f1
commit 9d3064a
Showing 1 changed file with 1 addition and 14 deletions.
diff --git a/distributed/utils.py b/distributed/utils.py
@@ -1124,21 +1124,8 @@ def color_of(x, palette=palette):
     return palette[n % len(palette)]
 
 
-def _iscoroutinefunction(f):
-    return inspect.iscoroutinefunction(f) or gen.is_coroutine_function(f)
-
-
-@functools.lru_cache(None)
-def _iscoroutinefunction_cached(f):
-    return _iscoroutinefunction(f)
-
-
 def iscoroutinefunction(f):
-    # Attempt to use lru_cache version and fall back to non-cached version if needed
-    try:
-        return _iscoroutinefunction_cached(f)
-    except TypeError:  # unhashable type
-        return _iscoroutinefunction(f)
+    return inspect.iscoroutinefunction(f) or gen.is_coroutine_function(f)
 
 
 @contextmanager