Drop `Optional` usage from marketstore module

marketstore_disable_snappy
Tyler Goodlet 2023-05-09 14:45:34 -04:00
parent 96532ad38c
commit f8c8f63e87
1 changed files with 6 additions and 7 deletions

View File

@ -28,7 +28,6 @@ from contextlib import asynccontextmanager as acm
from datetime import datetime from datetime import datetime
from typing import ( from typing import (
Any, Any,
Optional,
Union, Union,
TYPE_CHECKING, TYPE_CHECKING,
) )
@ -292,7 +291,7 @@ def mk_tbk(keys: tuple[str, str, str]) -> str:
def quote_to_marketstore_structarray( def quote_to_marketstore_structarray(
quote: dict[str, Any], quote: dict[str, Any],
last_fill: Optional[float] last_fill: float | None,
) -> np.array: ) -> np.array:
''' '''
@ -413,8 +412,8 @@ class Storage:
) -> tuple[ ) -> tuple[
np.ndarray, # timeframe sampled array-series np.ndarray, # timeframe sampled array-series
Optional[datetime], # first dt datetime | None, # first dt
Optional[datetime], # last dt datetime | None, # last dt
]: ]:
first_tsdb_dt, last_tsdb_dt = None, None first_tsdb_dt, last_tsdb_dt = None, None
@ -444,7 +443,7 @@ class Storage:
self, self,
fqsn: str, fqsn: str,
timeframe: int | str, timeframe: int | str,
end: Optional[int] = None, end: int | None = None,
limit: int = int(800e3), limit: int = int(800e3),
) -> np.ndarray: ) -> np.ndarray:
@ -519,7 +518,7 @@ class Storage:
async def delete_ts( async def delete_ts(
self, self,
key: str, key: str,
timeframe: Optional[Union[int, str]] = None, timeframe: Union[int, str | None] = None,
fmt: str = 'OHLCV', fmt: str = 'OHLCV',
) -> bool: ) -> bool:
@ -627,7 +626,7 @@ class Storage:
@acm @acm
async def open_storage_client( async def open_storage_client(
fqsn: str, fqsn: str,
period: Optional[Union[int, str]] = None, # in seconds period: Union[int, str | None] = None, # in seconds
) -> tuple[Storage, dict[str, np.ndarray]]: ) -> tuple[Storage, dict[str, np.ndarray]]:
''' '''