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

Raise cache miss on a disconnected ib client

pause_feeds_on_sym_switch
Tyler Goodlet 2021-08-18 15:15:28 -04:00
parent c6aa867c9b
commit ffbfd187ad
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
piker/brokers/ib.py
View File

@ -701,6 +701,10 @@ async def _aio_get_client(
# grab first cached client # grab first cached client
client = list(_client_cache.values())[0] client = list(_client_cache.values())[0]
if not client.ib.isConnected():
# we have a stale client to re-allocate
raise KeyError
yield client yield client
except (KeyError, IndexError): except (KeyError, IndexError):
@ -780,7 +784,6 @@ async def _aio_run_client_method(
kwargs['to_trio'] = to_trio kwargs['to_trio'] = to_trio
log.runtime(f'Running {meth}({kwargs})') log.runtime(f'Running {meth}({kwargs})')
return await async_meth(**kwargs) return await async_meth(**kwargs)