VER: Release databento-python 0.8.0

Author: cjdsellers

CHANGELOG.md

@@ -1,7 +1,7 @@
 # Changelog
 
-## 0.8.0 - TBD
-- Renamed 'dbz' encoding to 'dbn'
+## 0.8.0 - 2023-03-03
+- Integrate DBN encoding `0.3.2`
 - Renamed `timeseries.stream` to `timeseries.get_range`
 - Renamed `timeseries.stream_async` to `timeseries.get_range_async`
 - Deprecated `timeseries.stream(...)` method
@@ -12,6 +12,7 @@
 - Changed `.to_df(...)` `pretty_ts` default argument to `True`
 - Changed `.to_df(...)` `pretty_px` default argument to `True`
 - Changed `.to_df(...)` `map_symbols` default argument to `True`
+- Drop support for DBZ encoding
 
 ## 0.7.0 - 2023-01-10
 - Added support for `definition` schema

databento/historical/http.py

@@ -6,14 +6,12 @@
 import aiohttp
 import requests
 from aiohttp import ClientResponse
-from databento.common.logging import log_info
 from databento.historical.error import BentoClientError, BentoServerError
 from databento.version import __version__
 from requests import Response
 from requests.auth import HTTPBasicAuth
 
 
-_NO_DATA_FOUND = b"No data found for query."
 _32KB = 1024 * 32  # 32_768
 
 
@@ -114,9 +112,6 @@ def _stream(
             check_http_error(response)
 
             for chunk in response.iter_content(chunk_size=_32KB):
-                if chunk == _NO_DATA_FOUND:
-                    log_info("No data found for query.")
-                    break
                 writer.write(chunk)
 
     async def _stream_async(
@@ -141,11 +136,7 @@ async def _stream_async(
                 await check_http_error_async(response)
 
                 async for chunk in response.content.iter_chunks():
-                    data: bytes = chunk[0]
-                    if data == _NO_DATA_FOUND:
-                        log_info("No data found for query.")
-                        break
-                    writer.write(data)
+                    writer.write(chunk[0])
 
 
 def is_400_series_error(status: int) -> bool: