From cb8833d430d759fe78b08834af973970a9b3185f Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Tue, 9 May 2023 14:41:46 -0400
Subject: [PATCH] ib: clear error events on every received?

---
 piker/brokers/ib/api.py  | 2 +-
 piker/brokers/ib/feed.py | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

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': {