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

If more then one `ib` api client is available use next available for search

livenpaper
Tyler Goodlet 2022-08-22 17:52:47 -04:00
parent 848e345364
commit de9f215c83
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
piker/brokers/ib/feed.py
View File

@ -867,17 +867,24 @@ async def open_symbol_search(
# TODO: load user defined symbol set locally for fast search? # TODO: load user defined symbol set locally for fast search?
await ctx.started({}) await ctx.started({})
# async with open_data_client() as proxy:
async with ( async with (
open_client_proxies() as (proxies, clients), open_client_proxies() as (proxies, clients),
open_data_client() as data_proxy,
): ):
async with ctx.open_stream() as stream: async with ctx.open_stream() as stream:
# await tractor.breakpoint() # select a non-history client for symbol search to lighten
proxy = proxies['ib.algopaper'] # the load in the main data node.
proxy = data_proxy
for name, proxy in proxies.items():
if proxy is data_proxy:
continue
break
ib_client = proxy._aio_ns.ib
log.info(f'Using {ib_client} for symbol search')
last = time.time() last = time.time()
async for pattern in stream: async for pattern in stream:
log.info(f'received {pattern}') log.info(f'received {pattern}')
now = time.time() now = time.time()
@ -938,7 +945,9 @@ async def open_symbol_search(
await trio.sleep(0) await trio.sleep(0)
if cs.cancelled_caught: if cs.cancelled_caught:
log.warning(f'Search timeout? {proxy._aio_ns.ib.client}') log.warning(
f'Search timeout? {proxy._aio_ns.ib.client}'
)
continue continue
else: else:
break break