From d334e61b1f9440dc5003d8b4d56e6ccf44ef6c4f Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Fri, 15 Apr 2022 13:44:07 -0400 Subject: [PATCH] Drop 22s timeout on reset hack --- piker/brokers/ib.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/piker/brokers/ib.py b/piker/brokers/ib.py index 51724e5a..65d6f4c0 100644 --- a/piker/brokers/ib.py +++ b/piker/brokers/ib.py @@ -1519,13 +1519,13 @@ async def get_bars( ('history', hist_ev), # ('live', live_ev), ]: - with trio.move_on_after(22) as cs: - await ev.wait() - log.info(f"{name} DATA RESET") + # with trio.move_on_after(22) as cs: + await ev.wait() + log.info(f"{name} DATA RESET") - if cs.cancelled_caught: - log.warning("reset hack failed on first try?") - # await tractor.breakpoint() + # if cs.cancelled_caught: + # log.warning("reset hack failed on first try?") + # await tractor.breakpoint() fails += 1 continue @@ -1583,7 +1583,7 @@ async def backfill_bars( # 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 # memory. - count: int = 16, + count: int = 100, task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED,