diff --git a/stream_framework/utils/__init__.py b/stream_framework/utils/__init__.py
index 81a89798..306bfcca 100644
--- a/stream_framework/utils/__init__.py
+++ b/stream_framework/utils/__init__.py
@@ -116,7 +116,7 @@ def __init__(self, func):
         self.cache = LRUCache(10000)
 
     def __call__(self, *args):
-        if not isinstance(args, collections.Hashable):
+        if not isinstance(args, collections.abc.Hashable):
             # uncacheable. a list, for instance.
             # better to not cache than blow up.
             return self.func(*args)