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

Drop 22s timeout on reset hack

drop_arrow_add_predulum
Tyler Goodlet 2022-04-15 13:44:07 -04:00
parent fbabfb78e0
commit d334e61b1f
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
piker/brokers/ib.py
View File

@ -1519,13 +1519,13 @@ async def get_bars(
('history', hist_ev), ('history', hist_ev),
# ('live', live_ev), # ('live', live_ev),
]: ]:
with trio.move_on_after(22) as cs: # with trio.move_on_after(22) as cs:
await ev.wait() await ev.wait()
log.info(f"{name} DATA RESET") log.info(f"{name} DATA RESET")
if cs.cancelled_caught: # if cs.cancelled_caught:
log.warning("reset hack failed on first try?") # log.warning("reset hack failed on first try?")
# await tractor.breakpoint() # await tractor.breakpoint()
fails += 1 fails += 1
continue continue
@ -1583,7 +1583,7 @@ async def backfill_bars(
# on that until we have the `marketstore` daemon in place in which # on that until we have the `marketstore` daemon in place in which
# case the shm size will be driven by user config and available sys # case the shm size will be driven by user config and available sys
# memory. # memory.
count: int = 16, count: int = 100,
task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED, task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED,