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

ib: clear error events on every received?

marketstore_disable_snappy
Tyler Goodlet 2023-05-09 14:41:46 -04:00
parent 038b20d13a
commit cb8833d430
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piker/brokers/ib/api.py
View File

@ -1059,11 +1059,11 @@ class Client:
api_err, api_err,
report_api_err, report_api_err,
): ):
breakpoint()
to_trio.send_nowait(( to_trio.send_nowait((
'error', 'error',
msg, msg,
)) ))
api_err.clear() # drop msg history
api_err.connect(report_api_err) api_err.connect(report_api_err)

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

@ -837,6 +837,7 @@ async def stream_quotes(
# ibclient = proxy._aio_ns.ib.client # ibclient = proxy._aio_ns.ib.client
# host, port = ibclient.host, ibclient.port # host, port = ibclient.host, ibclient.port
fqsn = first_quote['fqsn']
# TODO: for loop through all symbols passed in # TODO: for loop through all symbols passed in
init_msgs: dict[str, dict] = { init_msgs: dict[str, dict] = {
@ -844,7 +845,7 @@ async def stream_quotes(
# and that history has been written # and that history has been written
sym: { sym: {
'symbol_info': syminfo, 'symbol_info': syminfo,
'fqsn': first_quote['fqsn'], 'fqsn': fqsn,
'bs_mktid': con.conId, 'bs_mktid': con.conId,
}, },
# 'status': { # 'status': {