TO-CHERRY: another sampler EoC suppression case?

Not sure whether this should get cherried onto `stop_is_eoc` or
`brokers_refinery` (need to a diff between the two first) but seems like
this might be the final resiliency update? 🙏

examples/max_pain.py

@@ -54,9 +54,13 @@ async def max_pain_daemon(
             kind=kind
         )
 
-        print(f'Available expiration dates for {currency}-{kind}:')
+        log.info(
-        print(f'{expiry_dates}')
+            f'Available expiries for {currency!r}-{kind}:\n'
-        expiry_date = input('Please enter a valid expiration date: ').upper()
+            f'{expiry_dates}\n'
+        )
+        expiry_date: str = input(
+            'Please enter a valid expiration date: '
+        ).upper()
         print('Starting little daemon...')
 
         # maybe move this type annot down to the assignment line?

piker/brokers/binance/venues.py

@@ -97,6 +97,8 @@ class Pair(Struct, frozen=True, kw_only=True):
     baseAsset: str
     baseAssetPrecision: int
 
+    permissionSets: list[list[str]]
+
     filters: dict[
         str,
         str | int | float,
@@ -142,7 +144,6 @@ class SpotPair(Pair, frozen=True):
     defaultSelfTradePreventionMode: str
     allowedSelfTradePreventionModes: list[str]
     permissions: list[str]
-    permissionSets: list[list[str]]
 
     # can the paint botz creat liq gaps even easier on this asset?
     # Bp

piker/brokers/deribit/api.py

@@ -1,5 +1,5 @@
 # piker: trading gear for hackers
-# Copyright (C) Guillermo Rodriguez (in stewardship for piker0)
+# Copyright (C) Guillermo Rodriguez (in stewardship for pikers)
 
 # This program is free software: you can redistribute it and/or modify
 # it under the terms of the GNU Affero General Public License as published by
@@ -80,7 +80,6 @@ from piker.accounting import (
 from piker.data import (
     def_iohlcv_fields,
     match_from_pairs,
-    # Struct,
 )
 from piker.data._web_bs import (
     open_jsonrpc_session
@@ -195,7 +194,11 @@ def cb_sym_to_deribit_inst(sym: Symbol) -> str:
 
 
 def get_values_from_cb_normalized_date(expiry_date: str) -> str:
-    # deribit specific
+    '''
+    Convert the `cryptofeed` (expiry) datetime format to our own,
+    a simple 3 token `str: f'{day}{month}{year}'.
+
+    '''
     cb_norm = [
         'F', 'G', 'H', 'J',
         'K', 'M', 'N', 'Q',

piker/cli/__init__.py

@@ -335,7 +335,7 @@ def services(config, tl, ports):
                 name='service_query',
                 loglevel=config['loglevel'] if tl else None,
             ),
-            tractor.get_arbiter(
+            tractor.get_registry(
                 host=host,
                 port=ports[0]
             ) as portal

piker/data/_sampling.py

@@ -284,7 +284,8 @@ class Sampler:
 
                     except (
                         trio.BrokenResourceError,
-                        trio.ClosedResourceError
+                        trio.ClosedResourceError,
+                        trio.EndOfChannel,
                     ):
                         log.error(
                             f'{stream._ctx.chan.uid} dropped connection'
@@ -697,7 +698,7 @@ async def sample_and_broadcast(
 
                                 log.warning(
                                     f'Feed OVERRUN {sub_key}'
-                                    '@{bus.brokername} -> \n'
+                                    f'@{bus.brokername} -> \n'
                                     f'feed @ {chan.uid}\n'
                                     f'throttle = {throttle} Hz'
                                 )