pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

Make linux timeout the same

mkts_backup
Tyler Goodlet 2022-02-28 08:12:40 -05:00
parent 40e62c1a38
commit 6c8b79906b
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
piker/brokers/ib.py
View File

@ -533,7 +533,6 @@ class Client:
f'Quote for {symbol} timed out: market is closed?' f'Quote for {symbol} timed out: market is closed?'
) )
# ticker = await ticker.updateEvent
else: else:
log.info(f'Got first quote for {symbol}') log.info(f'Got first quote for {symbol}')
break break
@ -811,7 +810,7 @@ async def load_aio_clients(
# try: # try:
# TODO: support multiple clients allowing for execution on # TODO: support multiple clients allowing for execution on
# multiple accounts (including a paper instance running on the # multiple accounts (including a paper instance running on the
# same machine) and switching between accounts in the EMs # same machine) and switching between accounts in the ems.
_err = None _err = None
@ -834,7 +833,7 @@ async def load_aio_clients(
# XXX: not sure if we ever really need to increment the # XXX: not sure if we ever really need to increment the
# client id if teardown is sucessful. # client id if teardown is sucessful.
client_id = 616 client_id = 6116
await ib.connectAsync( await ib.connectAsync(
host, host,
@ -910,13 +909,13 @@ async def load_aio_clients(
# cache logic to avoid rescanning if we already have all # cache logic to avoid rescanning if we already have all
# clients loaded. # clients loaded.
_scan_ignore.add(sockaddr) _scan_ignore.add(sockaddr)
else:
if not _client_cache: if not _client_cache:
raise ConnectionError( raise ConnectionError(
'No ib APIs could be found scanning @:\n' 'No ib APIs could be found scanning @:\n'
f'{pformat(combos)}\n' f'{pformat(combos)}\n'
'Check your `brokers.toml` and/or network' 'Check your `brokers.toml` and/or network'
) from _err ) from _err
# retreive first loaded client # retreive first loaded client
clients = list(_client_cache.values()) clients = list(_client_cache.values())
@ -1440,7 +1439,6 @@ async def stream_quotes(
''' '''
# TODO: support multiple subscriptions # TODO: support multiple subscriptions
sym = symbols[0] sym = symbols[0]
details: Optional[dict] = None
contract, first_ticker, details = await _trio_run_client_method( contract, first_ticker, details = await _trio_run_client_method(
method='get_sym_details', method='get_sym_details',