examples/max_pain.py

@@ -54,13 +54,9 @@ async def max_pain_daemon(
             kind=kind
         )
 
-        log.info(
-            f'Available expiries for {currency!r}-{kind}:\n'
-            f'{expiry_dates}\n'
-        )
-        expiry_date: str = input(
-            'Please enter a valid expiration date: '
-        ).upper()
+        print(f'Available expiration dates for {currency}-{kind}:')
+        print(f'{expiry_dates}')
+        expiry_date = 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,8 +97,6 @@ class Pair(Struct, frozen=True, kw_only=True):
     baseAsset: str
     baseAssetPrecision: int
 
-    permissionSets: list[list[str]]
-
     filters: dict[
         str,
         str | int | float,
@@ -144,6 +142,7 @@ 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 pikers)
+# Copyright (C) Guillermo Rodriguez (in stewardship for piker0)
 
 # 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,6 +80,7 @@ from piker.accounting import (
 from piker.data import (
     def_iohlcv_fields,
     match_from_pairs,
+    # Struct,
 )
 from piker.data._web_bs import (
     open_jsonrpc_session
@@ -194,11 +195,7 @@ def cb_sym_to_deribit_inst(sym: Symbol) -> str:
 
 
 def get_values_from_cb_normalized_date(expiry_date: str) -> str:
-    '''
-    Convert the `cryptofeed` (expiry) datetime format to our own,
-    a simple 3 token `str: f'{day}{month}{year}'.
-
-    '''
+    # deribit specific
     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_registry(
+            tractor.get_arbiter(
                 host=host,
                 port=ports[0]
             ) as portal

piker/data/_sampling.py

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