Skip to content

Commit 44a3a9f

Browse files
committed
fix #285, bump version
1 parent 229530c commit 44a3a9f

3 files changed

Lines changed: 34 additions & 2 deletions

File tree

tastytrade/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
API_VERSION = "20251101"
55
CERT_URL = "https://api.cert.tastyworks.com"
66
VAST_URL = "https://vast.tastyworks.com"
7-
VERSION = "11.0.2"
7+
VERSION = "11.0.3"
88

99
__version__ = VERSION
1010
version_str: str = f"tastyware/tastytrade:v{VERSION}"

tastytrade/order.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,7 @@ class PlacedOrder(TastytradeData):
316316
cancelled_at: datetime | None = None
317317
cancel_user_id: str | None = None
318318
cancel_username: str | None = None
319-
replacing_order_id: str | None = None
319+
replacing_order_id: int | None = None
320320
replaces_order_id: int | None = None
321321
in_flight_at: datetime | None = None
322322
live_at: datetime | None = None

tmp.py

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
import asyncio
2+
import os
3+
from datetime import date, datetime, time
4+
5+
import pandas as pd
6+
7+
from tastytrade import Session
8+
from tastytrade.dxfeed.candle import Candle
9+
from tastytrade.streamer import DXLinkStreamer
10+
from tastytrade.utils import TZ
11+
12+
session = Session(os.environ["TT_SECRET"], os.environ["TT_REFRESH"])
13+
14+
15+
async def main():
16+
async with DXLinkStreamer(session) as streamer:
17+
start_time = datetime.combine(date(2025, 11, 7), time(9, 30), tzinfo=TZ)
18+
ts = round(start_time.timestamp() * 1000)
19+
await streamer.subscribe_candle(["DIA"], "5s", start_time=start_time)
20+
candles: list[Candle] = []
21+
async for candle in streamer.listen(Candle):
22+
candles.append(candle)
23+
if candle.time <= ts:
24+
break
25+
candles.sort(key=lambda c: c.time)
26+
df = pd.DataFrame([c.model_dump() for c in candles])
27+
df = df[["time", "open", "high", "low", "close"]]
28+
print(df)
29+
30+
31+
if __name__ == "__main__":
32+
asyncio.run(main())

0 commit comments

Comments
 (0)