DEL: Remove sunset timeseries.stream endpoint

Author: cjdsellers

databento/common/dbnstore.py

@@ -3,6 +3,7 @@
 import abc
 import datetime as dt
 import logging
+from collections.abc import Generator
 from io import BytesIO
 from os import PathLike
 from pathlib import Path
@@ -12,7 +13,6 @@
     Any,
     Callable,
     Dict,
-    Generator,
     List,
     Optional,
     Union,
@@ -21,20 +21,25 @@
 import numpy as np
 import pandas as pd
 import zstandard
-from databento.common.data import (
-    COLUMNS,
-    DEFINITION_CHARARRAY_COLUMNS,
-    DEFINITION_PRICE_COLUMNS,
-    DEFINITION_TYPE_MAX_MAP,
-    DERIV_SCHEMAS,
-    STRUCT_MAP,
-)
-from databento.common.enums import Compression, Schema, SType
+from databento_dbn import DBNDecoder
+from databento_dbn import ErrorMsg
+from databento_dbn import Metadata
+from databento_dbn import SymbolMappingMsg
+from databento_dbn import SystemMsg
+
+from databento.common.data import COLUMNS
+from databento.common.data import DEFINITION_CHARARRAY_COLUMNS
+from databento.common.data import DEFINITION_PRICE_COLUMNS
+from databento.common.data import DEFINITION_TYPE_MAX_MAP
+from databento.common.data import DERIV_SCHEMAS
+from databento.common.data import STRUCT_MAP
+from databento.common.enums import Compression
+from databento.common.enums import Schema
+from databento.common.enums import SType
 from databento.common.error import BentoError
 from databento.common.symbology import InstrumentIdMappingInterval
 from databento.common.validation import validate_maybe_enum
 from databento.live.data import DBNStruct
-from databento_dbn import DBNDecoder, ErrorMsg, Metadata, SymbolMappingMsg, SystemMsg
 
 
 NON_SCHEMA_RECORD_TYPES = [
@@ -487,8 +492,7 @@ def _map_symbols(self, df: pd.DataFrame, pretty_ts: bool) -> pd.DataFrame:
             df_index = df.index if pretty_ts else pd.to_datetime(df.index, utc=True)
             dates = [ts.date() for ts in df_index]
             df["symbol"] = [
-                self._instrument_id_index[dates[i]][p]
-                for i, p in enumerate(df["instrument_id"])
+                self._instrument_id_index[dates[i]][p] for i, p in enumerate(df["instrument_id"])
             ]
 
         return df
@@ -790,7 +794,7 @@ def request_full_definitions(
         """
         Request full instrument definitions based on the metadata properties.
 
-        Makes a `GET /timeseries.stream` HTTP request.
+        Makes a `GET /timeseries.get_range` HTTP request.
 
         Parameters
         ----------
@@ -808,7 +812,7 @@ def request_full_definitions(
         Calling this method will incur a cost.
 
         """
-        return client.timeseries.stream(
+        return client.timeseries.get_range(
             dataset=self.dataset,
             symbols=self.symbols,
             schema=Schema.DEFINITION,

databento/historical/api/timeseries.py

@@ -2,21 +2,26 @@
 
 import warnings
 from datetime import date
-from io import BufferedIOBase, BytesIO
+from io import BufferedIOBase
+from io import BytesIO
 from os import PathLike
 from typing import List, Optional, Tuple, Union
 
 import pandas as pd
+
 from databento.common.dbnstore import DBNStore
 from databento.common.deprecated import deprecated
-from databento.common.enums import Compression, Dataset, Encoding, Schema, SType
+from databento.common.enums import Compression
+from databento.common.enums import Dataset
+from databento.common.enums import Encoding
+from databento.common.enums import Schema
+from databento.common.enums import SType
 from databento.common.error import BentoWarning
-from databento.common.parsing import (
-    datetime_to_string,
-    optional_datetime_to_string,
-    optional_symbols_list_to_string,
-)
-from databento.common.validation import validate_enum, validate_semantic_string
+from databento.common.parsing import datetime_to_string
+from databento.common.parsing import optional_datetime_to_string
+from databento.common.parsing import optional_symbols_list_to_string
+from databento.common.validation import validate_enum
+from databento.common.validation import validate_semantic_string
 from databento.historical.api import API_VERSION
 from databento.historical.api.metadata import MetadataHttpAPI
 from databento.historical.http import BentoHttpAPI
@@ -34,35 +39,6 @@ def __init__(self, key: str, gateway: str) -> None:
         super().__init__(key=key, gateway=gateway)
         self._base_url = gateway + f"/v{API_VERSION}/timeseries"
 
-    @deprecated
-    def stream(
-        self,
-        dataset: Union[Dataset, str],
-        start: Union[pd.Timestamp, date, str, int],
-        end: Optional[Union[pd.Timestamp, date, str, int]] = None,
-        symbols: Optional[Union[List[str], str]] = None,
-        schema: Union[Schema, str] = "trades",
-        stype_in: Union[SType, str] = "raw_symbol",
-        stype_out: Union[SType, str] = "instrument_id",
-        limit: Optional[int] = None,
-        path: Optional[Union[PathLike[str], str]] = None,
-    ) -> DBNStore:
-        """
-        The `.stream` method is deprecated and will be removed in a future version.
-        The method has been renamed to `.get_range`, which you can now use.
-        """
-        return self.get_range(
-            dataset=dataset,
-            start=start,
-            end=end,
-            symbols=symbols,
-            schema=schema,
-            stype_in=stype_in,
-            stype_out=stype_out,
-            limit=limit,
-            path=path,
-        )
-
     def get_range(
         self,
         dataset: Union[Dataset, str],