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

Import missing `_accounts2clients` table

ib_subpkg
Tyler Goodlet 2022-06-07 09:48:51 -04:00
parent 569674517f
commit 1345b250bc
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
piker/brokers/ib/broker.py
View File

@ -57,6 +57,7 @@ from piker.clearing._messages import (
BrokerdError, BrokerdError,
) )
from .api import ( from .api import (
_accounts2clients,
_adhoc_futes_set, _adhoc_futes_set,
log, log,
get_config, get_config,
@ -112,8 +113,6 @@ async def handle_order_requests(
) -> None: ) -> None:
global _accounts2clients
request_msg: dict request_msg: dict
async for request_msg in ems_order_stream: async for request_msg in ems_order_stream:
log.info(f'Received order request {request_msg}') log.info(f'Received order request {request_msg}')
@ -271,7 +270,6 @@ async def trades_dialogue(
accounts_def = config.load_accounts(['ib']) accounts_def = config.load_accounts(['ib'])
global _accounts2clients
global _client_cache global _client_cache
# deliver positions to subscriber before anything else # deliver positions to subscriber before anything else
@ -283,7 +281,6 @@ async def trades_dialogue(
trio.open_nursery() as nurse, trio.open_nursery() as nurse,
open_client_proxies() as (proxies, aioclients), open_client_proxies() as (proxies, aioclients),
): ):
# for account, client in _accounts2clients.items():
for account, proxy in proxies.items(): for account, proxy in proxies.items():
client = aioclients[account] client = aioclients[account]