Enable console log (from passed down `loglevel`) in `.tsp._history.manage_history()`

Replace the debug breakpoint with a warning-log when a single-bar
null-segment is detected in `get_null_segs()`. This lets the gap
analysis continue while still alerting about the anomaly.

Deats,
- extract the 3-bar window (before, null, after) and calculate
  a `gap: pendulum.Interval` for the warning msg.
- comment-out the old breakpoint block for optional debugging as needed.

(this commit msg was generated in some part by [`claude-code`][claude-code-gh])
[claude-code-gh]: https://github.com/anthropics/claude-code

piker/brokers/ib/broker.py

@@ -991,6 +991,9 @@ _statuses: dict[str, str] = {
     # TODO: see a current ``ib_insync`` issue around this:
     # https://github.com/erdewit/ib_insync/issues/363
     'Inactive': 'pending',
+
+    # XXX, uhh wut the heck is this?
+    'ValidationError': 'error',
 }
 
 _action_map = {
@@ -1063,8 +1066,19 @@ async def deliver_trade_events(
     # TODO: for some reason we can receive a ``None`` here when the
     # ib-gw goes down? Not sure exactly how that's happening looking
     # at the eventkit code above but we should probably handle it...
+    event_name: str
+    item: (
+        Trade
+        |tuple[Trade, Fill]
+        |CommissionReport
+        |IbPosition
+        |dict
+    )
     async for event_name, item in trade_event_stream:
-        log.info(f'Relaying `{event_name}`:\n{pformat(item)}')
+        log.info(
+            f'Relaying {event_name!r}:\n'
+            f'{pformat(item)}\n'
+        )
         match event_name:
             case 'orderStatusEvent':
 
@@ -1075,11 +1089,12 @@ async def deliver_trade_events(
                 trade: Trade = item
                 reqid: str = str(trade.order.orderId)
                 status: OrderStatus = trade.orderStatus
-                status_str: str = _statuses[status.status]
+                status_str: str = _statuses.get(
+                    status.status,
+                    'error',
+                )
                 remaining: float = status.remaining
-                if (
-                    status_str == 'filled'
-                ):
+                if status_str == 'filled':
                     fill: Fill = trade.fills[-1]
                     execu: Execution = fill.execution
 
@@ -1110,6 +1125,12 @@ async def deliver_trade_events(
                         # all units were cleared.
                         status_str = 'closed'
 
+                elif status_str == 'error':
+                    log.error(
+                        f'IB reported error status for order ??\n'
+                        f'{status.status!r}\n'
+                    )
+
                 # skip duplicate filled updates - we get the deats
                 # from the execution details event
                 msg = BrokerdStatus(

piker/brokers/ib/venues.py

@@ -83,7 +83,14 @@ def has_holiday(
     '''
     tz: str = con_deats.timeZoneId
     exch: str = con_deats.contract.primaryExchange
-    cal: ExchangeCalendar = xcals.get_calendar(exch)
+
+    # XXX, ad-hoc handle any IB exchange which are non-std
+    # via lookup table..
+    std_exch: dict = {
+        'ARCA': 'ARCX',
+    }.get(exch, exch)
+
+    cal: ExchangeCalendar = xcals.get_calendar(std_exch)
     end: datetime = period.end
     # _start: datetime = period.start
     # ?TODO, can rm ya?

piker/tsp/_history.py

@@ -58,7 +58,10 @@ from piker.brokers import NoData
 from piker.accounting import (
     MktPair,
 )
-from piker.log import get_logger
+from piker.log import (
+    get_logger,
+    get_console_log,
+)
 from ..data._sharedmem import (
     maybe_open_shm_array,
     ShmArray,
@@ -1368,6 +1371,10 @@ async def manage_history(
         engages.
 
     '''
+    get_console_log(
+        name=__name__,
+        level=loglevel,
+    )
     # TODO: is there a way to make each shm file key
     # actor-tree-discovery-addr unique so we avoid collisions
     # when doing tests which also allocate shms for certain instruments