Skip to content

Commit

Permalink
small tweaks
Browse files Browse the repository at this point in the history
  • Loading branch information
Graeme22 committed Dec 16, 2024
1 parent 6e9c0eb commit c66306e
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions tastytrade/streamer.py
Original file line number Diff line number Diff line change
Expand Up @@ -409,7 +409,6 @@ def __init__(
#: Variable number of arguments to pass to the reconnect function
self.reconnect_args = reconnect_args

self._session = session
self._authenticated = False
self._wss_url = session.dxlink_url
self._auth_token = session.streamer_token
Expand Down Expand Up @@ -663,7 +662,7 @@ async def unsubscribe(
Removes existing subscription for given list of symbols.
For candles, use :meth:`unsubscribe_candle` instead.
:param event_type: type of subscription to remove
:param event_class: type of subscription to remove
:param symbols: list of symbols to unsubscribe from
"""
if not self._authenticated:
Expand All @@ -682,11 +681,10 @@ async def subscribe_candle(
symbols: list[str],
interval: str,
start_time: datetime,
end_time: Optional[datetime] = None,
extended_trading_hours: bool = False,
) -> None:
"""
Subscribes to time series data for the given symbol.
Subscribes to candle data for the given list of symbols.
:param symbols: list of symbols to get data for
:param interval:
Expand Down Expand Up @@ -715,8 +713,6 @@ async def subscribe_candle(
for ticker in symbols
],
}
if end_time is not None:
raise TastytradeError("End time no longer supported")
await self._websocket.send(json.dumps(message))

async def unsubscribe_candle(
Expand Down

0 comments on commit c66306e

Please sign in to comment.