FIX: Fix pipeline errors in client library

Author: nmacholl

CHANGELOG.md

@@ -1,5 +1,10 @@
 # Changelog
 
+## 0.15.1 - TBD
+
+#### Bug Fixes
+- Fixed an `ImportError` observed in Python 3.8
+
 ## 0.15.0 - 2023-07-03
 
 #### Enhancements

databento/common/parsing.py

@@ -88,7 +88,7 @@ def optional_symbols_list_to_list(
     )
 
 
-@optional_symbols_list_to_list.register
+@optional_symbols_list_to_list.register(cls=type(None))
 def _(_: None, __: SType) -> list[str]:
     """
     Dispatch method for optional_symbols_list_to_list. Handles None which
@@ -102,7 +102,7 @@ def _(_: None, __: SType) -> list[str]:
     return [ALL_SYMBOLS]
 
 
-@optional_symbols_list_to_list.register
+@optional_symbols_list_to_list.register(cls=Number)
 def _(symbols: Number, stype_in: SType) -> list[str]:
     """
     Dispatch method for optional_symbols_list_to_list. Handles numerical types,
@@ -121,7 +121,7 @@ def _(symbols: Number, stype_in: SType) -> list[str]:
     )
 
 
-@optional_symbols_list_to_list.register
+@optional_symbols_list_to_list.register(cls=str)
 def _(symbols: str, stype_in: SType) -> list[str]:
     """
     Dispatch method for optional_symbols_list_to_list. Handles str, splitting

databento/version.py

@@ -1 +1 @@
-__version__ = "0.15.0"
+__version__ = "0.15.1"

tests/mock_live_server.py

@@ -616,7 +616,10 @@ def get_message_of_type(
         end_time = self._loop.time() + timeout
         while start_time < end_time:
             remaining_time = abs(end_time - self._loop.time())
-            message = self._message_queue.get(timeout=remaining_time)
+            try:
+                message = self._message_queue.get(timeout=remaining_time)
+            except queue.Empty:
+                continue
 
             if isinstance(message, message_type):
                 return message