pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Fix type annot

cached_feeds
Tyler Goodlet 2021-03-31 14:05:16 -04:00
parent b2eacb85d4
commit 1d013126b9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
piker/brokers/ib.py
View File

@ -798,7 +798,6 @@ async def backfill_bars(
# write historical data to buffer # write historical data to buffer
shm.push(bars_array) shm.push(bars_array)
# shm_token = shm.token
with trio.CancelScope() as cs: with trio.CancelScope() as cs:
@ -939,6 +938,7 @@ async def start_aio_quote_stream(
async def stream_quotes( async def stream_quotes(
send_chan: trio.abc.SendChannel, send_chan: trio.abc.SendChannel,
symbols: List[str], symbols: List[str],
shm: ShmArray, shm: ShmArray,
@ -946,7 +946,7 @@ async def stream_quotes(
loglevel: str = None, loglevel: str = None,
# startup sync # startup sync
task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED, task_status: TaskStatus[Tuple[Dict, Dict]] = trio.TASK_STATUS_IGNORED,
) -> None: ) -> None:
"""Stream symbol quotes. """Stream symbol quotes.