diff --git a/piker/brokers/ib/api.py b/piker/brokers/ib/api.py index 1ac4b6af..0ad9683e 100644 --- a/piker/brokers/ib/api.py +++ b/piker/brokers/ib/api.py @@ -1059,11 +1059,11 @@ class Client: api_err, report_api_err, ): - breakpoint() to_trio.send_nowait(( 'error', msg, )) + api_err.clear() # drop msg history api_err.connect(report_api_err) diff --git a/piker/brokers/ib/feed.py b/piker/brokers/ib/feed.py index 86fdc095..df1eea6a 100644 --- a/piker/brokers/ib/feed.py +++ b/piker/brokers/ib/feed.py @@ -837,6 +837,7 @@ async def stream_quotes( # ibclient = proxy._aio_ns.ib.client # host, port = ibclient.host, ibclient.port + fqsn = first_quote['fqsn'] # TODO: for loop through all symbols passed in init_msgs: dict[str, dict] = { @@ -844,7 +845,7 @@ async def stream_quotes( # and that history has been written sym: { 'symbol_info': syminfo, - 'fqsn': first_quote['fqsn'], + 'fqsn': fqsn, 'bs_mktid': con.conId, }, # 'status': {