Fixes thread-safety issue in Message.types() (#151)

* Fixes thread-safety issue in Message.types() * Bump version to 3.9.1
rigetti · Apr 19, 2021 · 3a73471 · 3a73471
1 parent f5faec9
commit 3a73471
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 9 deletions.
diff --git a/VERSION.txt b/VERSION.txt
@@ -1 +1 @@
-3.9.0
+3.9.1
diff --git a/rpcq/_base.py b/rpcq/_base.py
@@ -109,7 +109,7 @@ def __eq__(self, other):
     def __hash__(self):
         return hash((self.__class__, astuple(self)))
 
-    _types = None
+    _types = {}
 
     @staticmethod
     def types():
@@ -120,13 +120,12 @@ def types():
         :return: A dictionary of ``Message`` types.
         :rtype: Dict[str,type]
         """
-        if Message._types is None:
-            Message._types = {}
-            classes_to_process = [Message]
-            while classes_to_process:
-                atom = classes_to_process.pop()
-                classes_to_process += atom.__subclasses__()
-                Message._types[atom.__name__] = (atom, inspect.getfullargspec(atom.__init__).args)
+        classes_to_process = [Message]
+        while classes_to_process:
+            atom = classes_to_process.pop()
+            classes_to_process += atom.__subclasses__()
+            Message._types[atom.__name__] = (atom, inspect.getfullargspec(atom.__init__).args)
+
         return Message._types