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

Kill backfiller on "no history" error

y_zoom
Tyler Goodlet 2021-01-01 12:34:50 -05:00
parent 81b10b9dfc
commit 5fddb581ab
1 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
piker/brokers/ib.py
View File

@ -622,7 +622,8 @@ async def fill_bars(
sym: str, sym: str,
first_bars: list, first_bars: list,
shm: 'ShmArray', # type: ignore # noqa shm: 'ShmArray', # type: ignore # noqa
count: int = 21, # NOTE: any more and we'll overrun the underlying buffer # count: int = 20, # NOTE: any more and we'll overrun the underlying buffer
count: int = 2, # NOTE: any more and we'll overrun the underlying buffer
) -> None: ) -> None:
"""Fill historical bars into shared mem / storage afap. """Fill historical bars into shared mem / storage afap.
@ -647,11 +648,23 @@ async def fill_bars(
next_dt = bars[0].date next_dt = bars[0].date
except RequestError as err: except RequestError as err:
# TODO: retreive underlying ``ib_insync`` error~~ # TODO: retreive underlying ``ib_insync`` error?
if err.code == 162: if err.code == 162:
if 'HMDS query returned no data' in err.message:
# means we hit some kind of historical "dead zone"
# and further requests seem to always cause
# throttling despite the rps being low
break
else:
log.exception( log.exception(
"Data query rate reached: Press `ctrl-alt-f` in TWS") "Data query rate reached: Press `ctrl-alt-f` in TWS")
# TODO: should probably create some alert on screen
# and then somehow get that to trigger an event here
# that restarts/resumes this task?
await tractor.breakpoint() await tractor.breakpoint()