From ac7ba500beba82562459e834a21c148873e1e8be Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Sat, 17 Sep 2022 14:15:24 -0400
Subject: [PATCH] Pass back interal cancel scope from data reset task

---
 piker/brokers/ib/feed.py | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/piker/brokers/ib/feed.py b/piker/brokers/ib/feed.py
index e0da8d1c..5117962f 100644
--- a/piker/brokers/ib/feed.py
+++ b/piker/brokers/ib/feed.py
@@ -192,7 +192,6 @@ async def wait_on_data_reset(
 
         log.warning('Sending DATA RESET request')
         await data_reset_hack(reset_type='data')
-        task_status.started()
 
         with trio.move_on_after(timeout) as cs:
             for name, ev in [
@@ -203,16 +202,18 @@ async def wait_on_data_reset(
                 # sent?
                 ('history', hist_ev),
             ]:
+                task_status.started(cs)
                 await ev.wait()
                 log.info(f"{name} DATA RESET")
                 break
 
-        if cs.cancelled_caught:
-            # fails += 1
+        if (
+            cs.cancelled_caught
+            and not cs.cancel_called
+        ):
             log.warning(
                 f'Data reset {name} timeout, retrying {i}.'
             )
-
             continue
     else:
 
@@ -223,7 +224,6 @@ async def wait_on_data_reset(
                 'NO VNC DETECTED!\n'
                 'Manually press ctrl-alt-f on your IB java app'
             )
-            # break
 
         with trio.move_on_after(timeout) as cs:
             for name, ev in [
@@ -238,7 +238,6 @@ async def wait_on_data_reset(
                 log.info(f"{name} DATA RESET")
 
         if cs.cancelled_caught:
-            # fails += 1
             log.warning('Data CONNECTION RESET timeout!?')
 
 
@@ -246,7 +245,7 @@ async def get_bars(
 
     proxy: MethodProxy,
     fqsn: str,
-    period: float,
+    timeframe: int,
 
     # blank to start which tells ib to look up the latest datum
     end_dt: str = '',
@@ -276,7 +275,7 @@ async def get_bars(
                     out = await proxy.bars(
                         fqsn=fqsn,
                         end_dt=end_dt,
-                        sample_period_s=period,
+                        sample_period_s=timeframe,
                     )
                     timeout = 3
 
@@ -563,10 +562,11 @@ async def _setup_quote_stream(
                 # Manually do the dereg ourselves.
                 teardown()
             except trio.WouldBlock:
-                log.warning(
-                    f'channel is blocking symbol feed for {symbol}?'
-                    f'\n{to_trio.statistics}'
-                )
+                # log.warning(
+                #     f'channel is blocking symbol feed for {symbol}?'
+                #     f'\n{to_trio.statistics}'
+                # )
+                pass
 
             # except trio.WouldBlock:
             #     # for slow debugging purposes to avoid clobbering prompt