VER: Release 0.16.1

See release notes.

Author: nmacholl

CHANGELOG.md

@@ -1,5 +1,11 @@
 # Changelog
 
+## 0.16.1 - 2023-08-03
+
+#### Bug fixes
+- Fixed an issue where starting a `Live` client before subscribing gave an incorrect error message
+- Fixed an issue where a `Live` client exception callback would fail when the callback function does not have a `__name__` attribute
+
 ## 0.16.0 - 2023-07-25
 
 This release includes updates to the fields in text encodings (CSV and JSON), you can read more about the changes [here](https://databento.com/blog/CSV-JSON-updates-july-2023).

databento/common/data.py

@@ -86,7 +86,8 @@ def get_deriv_ba_types(level: int) -> list[tuple[str, type | str]]:
 ]
 
 
-OHLCV_MSG: list[tuple[str, type | str]] = RECORD_HEADER + [
+OHLCV_MSG: list[tuple[str, type | str]] = [
+    *RECORD_HEADER,
     ("open", np.int64),
     ("high", np.int64),
     ("low", np.int64),
@@ -162,7 +163,8 @@ def get_deriv_ba_types(level: int) -> list[tuple[str, type | str]]:
     ("dummy", "S3"),  # 3 byte chararray (Adjustment filler for 8-bytes alignment)
 ]
 
-IMBALANCE_MSG: list[tuple[str, type | str]] = RECORD_HEADER + [
+IMBALANCE_MSG: list[tuple[str, type | str]] = [
+    *RECORD_HEADER,
     ("ts_recv", np.uint64),
     ("ref_price", np.int64),
     ("auction_time", np.uint64),
@@ -186,7 +188,8 @@ def get_deriv_ba_types(level: int) -> list[tuple[str, type | str]]:
     ("dummy", "S1"),
 ]
 
-STATISTICS_MSG: list[tuple[str, type | str]] = RECORD_HEADER + [
+STATISTICS_MSG: list[tuple[str, type | str]] = [
+    *RECORD_HEADER,
     ("ts_recv", np.uint64),
     ("ts_ref", np.uint64),
     ("price", np.int64),
@@ -404,7 +407,8 @@ def get_deriv_ba_fields(level: int) -> list[str]:
     "ind_match_price",
     "upper_collar",
     "lower_collar",
-    "paired_qty","total_imbalance_qty",
+    "paired_qty",
+    "total_imbalance_qty",
     "market_imbalance_qty",
     "unpaired_qty",
     "auction_type",

databento/live/client.py

@@ -357,6 +357,7 @@ def start(
         ValueError
             If `start()` is called before a subscription has been made.
             If `start()` is called after streaming has already started.
+            If `start()` is called after the live session has closed.
 
         See Also
         --------
@@ -365,6 +366,8 @@ def start(
         """
         logger.info("starting live client")
         if not self.is_connected():
+            if self.dataset == "":
+                raise ValueError("cannot start a live client without a subscription")
             raise ValueError("cannot start a live client after it is closed")
         if self._session.is_started():
             raise ValueError("client is already started")

databento/live/session.py

@@ -197,7 +197,7 @@ async def _callback_task(
             logger.error(
                 "error dispatching %s to `%s` callback",
                 type(record).__name__,
-                record_callback.__name__,
+                getattr(record_callback, "__name__", str(record_callback)),
                 exc_info=exc,
             )
             if exception_callback is not None:
@@ -527,7 +527,7 @@ async def _connect_task(
                 f"{AUTH_TIMEOUT_SECONDS} second(s).",
             ) from None
         except ValueError as exc:
-            raise BentoError(f"User authentication failed: {str(exc)}") from None
+            raise BentoError(f"User authentication failed: {exc!s}") from None
 
         logger.info(
             "authentication with remote gateway completed",

databento/version.py

@@ -1 +1 @@
-__version__ = "0.16.0"
+__version__ = "0.16.1"

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "databento"
-version = "0.16.0"
+version = "0.16.1"
 description = "Official Python client library for Databento"
 authors = [
     "Databento <[email protected]>",

tests/test_historical_bento.py

@@ -215,7 +215,7 @@ def test_to_ndarray_with_stub_data_returns_expected_array(
     assert isinstance(array, np.ndarray)
     assert (
         str(array)
-        == "[(14, 160, 1, 5482, 1609160400000429831, 647784973705, 3722750000000, 1, 128, 0, b'C', b'A', 1609160400000704060, 22993, 1170352)\n (14, 160, 1, 5482, 1609160400000431665, 647784973631, 3723000000000, 1, 128, 0, b'C', b'A', 1609160400000711344, 19621, 1170353)\n (14, 160, 1, 5482, 1609160400000433051, 647784973427, 3723250000000, 1, 128, 0, b'C', b'A', 1609160400000728600, 16979, 1170354)\n (14, 160, 1, 5482, 1609160400000434353, 647784973094, 3723500000000, 1, 128, 0, b'C', b'A', 1609160400000740248, 17883, 1170355)]"  # noqa
+        == "[(14, 160, 1, 5482, 1609160400000429831, 647784973705, 3722750000000, 1, 128, 0, b'C', b'A', 1609160400000704060, 22993, 1170352)\n (14, 160, 1, 5482, 1609160400000431665, 647784973631, 3723000000000, 1, 128, 0, b'C', b'A', 1609160400000711344, 19621, 1170353)\n (14, 160, 1, 5482, 1609160400000433051, 647784973427, 3723250000000, 1, 128, 0, b'C', b'A', 1609160400000728600, 16979, 1170354)\n (14, 160, 1, 5482, 1609160400000434353, 647784973094, 3723500000000, 1, 128, 0, b'C', b'A', 1609160400000740248, 17883, 1170355)]"
     )
 
 

tests/test_historical_error.py

@@ -80,7 +80,7 @@ def test_client_error_str_and_repr() -> None:
     assert str(error) == "400 Bad Request"
     assert (
         repr(error)
-        == "BentoClientError(request_id=None, http_status=400, message=Bad Request)"  # noqa
+        == "BentoClientError(request_id=None, http_status=400, message=Bad Request)"
     )
 
 
@@ -96,5 +96,5 @@ def test_server_error_str_and_repr() -> None:
     assert str(error) == "500 Internal Server Error"
     assert (
         repr(error)
-        == "BentoServerError(request_id=None, http_status=500, message=Internal Server Error)"  # noqa
+        == "BentoServerError(request_id=None, http_status=500, message=Internal Server Error)"
     )

tests/test_historical_metadata.py

@@ -176,7 +176,7 @@ def test_get_dataset_condition_sends_expected_request(
     call = mocked_get.call_args.kwargs
     assert (
         call["url"]
-        == f"{historical_client.gateway}/v{db.API_VERSION}/metadata.get_dataset_condition"  # noqa
+        == f"{historical_client.gateway}/v{db.API_VERSION}/metadata.get_dataset_condition"
     )
     assert ("dataset", "GLBX.MDP3") in call["params"]
     assert ("start_date", "2018-01-01") in call["params"]
@@ -202,7 +202,7 @@ def test_get_dataset_range_sends_expected_request(
     call = mocked_get.call_args.kwargs
     assert (
         call["url"]
-        == f"{historical_client.gateway}/v{db.API_VERSION}/metadata.get_dataset_range"  # noqa
+        == f"{historical_client.gateway}/v{db.API_VERSION}/metadata.get_dataset_range"
     )
     assert sorted(call["headers"].keys()) == ["accept", "user-agent"]
     assert call["headers"]["accept"] == "application/json"
@@ -274,7 +274,7 @@ def test_get_billable_size_sends_expected_request(
     call = mocked_get.call_args.kwargs
     assert (
         call["url"]
-        == f"{historical_client.gateway}/v{db.API_VERSION}/metadata.get_billable_size"  # noqa
+        == f"{historical_client.gateway}/v{db.API_VERSION}/metadata.get_billable_size"
     )
     assert sorted(call["headers"].keys()) == ["accept", "user-agent"]
     assert call["headers"]["accept"] == "application/json"

tests/test_live_client.py

@@ -309,6 +309,14 @@ def test_live_start_twice(
     with pytest.raises(ValueError):
         live_client.start()
 
+def test_live_start_before_subscribe(
+    live_client: client.Live,
+) -> None:
+    """
+    Test that calling start() before subscribe raises a ValueError.
+    """
+    with pytest.raises(ValueError):
+        live_client.start()
 
 @pytest.mark.parametrize(
     "schema",