|
1 | 1 | import datetime as dt |
2 | | -from typing import Callable |
| 2 | +from collections.abc import Callable |
3 | 3 | from typing import Generic |
4 | 4 | from typing import TypedDict |
5 | 5 | from typing import TypeVar |
6 | | -from typing import Union |
7 | 6 |
|
8 | 7 | import databento_dbn |
9 | 8 | import pandas as pd |
10 | 9 |
|
11 | 10 |
|
12 | | -DBNRecord = Union[ |
13 | | - databento_dbn.BBOMsg, |
14 | | - databento_dbn.CBBOMsg, |
15 | | - databento_dbn.CMBP1Msg, |
16 | | - databento_dbn.MBOMsg, |
17 | | - databento_dbn.MBP1Msg, |
18 | | - databento_dbn.MBP10Msg, |
19 | | - databento_dbn.TradeMsg, |
20 | | - databento_dbn.OHLCVMsg, |
21 | | - databento_dbn.ImbalanceMsg, |
22 | | - databento_dbn.InstrumentDefMsg, |
23 | | - databento_dbn.InstrumentDefMsgV1, |
24 | | - databento_dbn.InstrumentDefMsgV2, |
25 | | - databento_dbn.StatMsg, |
26 | | - databento_dbn.StatMsgV1, |
27 | | - databento_dbn.StatusMsg, |
28 | | - databento_dbn.SymbolMappingMsg, |
29 | | - databento_dbn.SymbolMappingMsgV1, |
30 | | - databento_dbn.SystemMsg, |
31 | | - databento_dbn.SystemMsgV1, |
32 | | - databento_dbn.ErrorMsg, |
33 | | - databento_dbn.ErrorMsgV1, |
34 | | -] |
| 11 | +DBNRecord = ( |
| 12 | + databento_dbn.BBOMsg |
| 13 | + | databento_dbn.CBBOMsg |
| 14 | + | databento_dbn.CMBP1Msg |
| 15 | + | databento_dbn.MBOMsg |
| 16 | + | databento_dbn.MBP1Msg |
| 17 | + | databento_dbn.MBP10Msg |
| 18 | + | databento_dbn.TradeMsg |
| 19 | + | databento_dbn.OHLCVMsg |
| 20 | + | databento_dbn.ImbalanceMsg |
| 21 | + | databento_dbn.InstrumentDefMsg |
| 22 | + | databento_dbn.InstrumentDefMsgV1 |
| 23 | + | databento_dbn.InstrumentDefMsgV2 |
| 24 | + | databento_dbn.StatMsg |
| 25 | + | databento_dbn.StatMsgV1 |
| 26 | + | databento_dbn.StatusMsg |
| 27 | + | databento_dbn.SymbolMappingMsg |
| 28 | + | databento_dbn.SymbolMappingMsgV1 |
| 29 | + | databento_dbn.SystemMsg |
| 30 | + | databento_dbn.SystemMsgV1 |
| 31 | + | databento_dbn.ErrorMsg |
| 32 | + | databento_dbn.ErrorMsgV1 |
| 33 | +) |
35 | 34 |
|
36 | 35 | RecordCallback = Callable[[DBNRecord], None] |
37 | 36 | ExceptionCallback = Callable[[Exception], None] |
|
0 commit comments