diff --git a/piker/brokers/deribit/api.py b/piker/brokers/deribit/api.py index c0ab1ed4..df617d75 100644 --- a/piker/brokers/deribit/api.py +++ b/piker/brokers/deribit/api.py @@ -586,7 +586,7 @@ async def open_price_feed( fh, instrument ) - ) as (first, chan): + ) as (chan, first): yield chan @@ -653,7 +653,7 @@ async def open_order_feed( fh, instrument ) - ) as (first, chan): + ) as (chan, first): yield chan diff --git a/piker/brokers/ib/api.py b/piker/brokers/ib/api.py index b40d4cbc..1cc5e4e0 100644 --- a/piker/brokers/ib/api.py +++ b/piker/brokers/ib/api.py @@ -1529,7 +1529,7 @@ async def open_client_proxies() -> tuple[ # TODO: maybe this should be the default in tractor? key=tractor.current_actor().uid, - ) as (cache_hit, (clients, _)), + ) as (cache_hit, (_, clients)), AsyncExitStack() as stack ): @@ -1718,7 +1718,7 @@ async def open_client_proxy( open_aio_client_method_relay, client=client, event_consumers=event_table, - ) as (first, chan), + ) as (chan, first), trionics.collapse_eg(), # loose-ify trio.open_nursery() as relay_tn, diff --git a/piker/brokers/ib/broker.py b/piker/brokers/ib/broker.py index 0705fc21..31703fb9 100644 --- a/piker/brokers/ib/broker.py +++ b/piker/brokers/ib/broker.py @@ -514,8 +514,8 @@ async def open_trade_event_stream( recv_trade_updates, client=client, ) as ( - _, # first pushed val trade_event_stream, + _, # first pushed val ): task_status.started(trade_event_stream) # block forever to keep session trio-asyncio session diff --git a/piker/brokers/ib/feed.py b/piker/brokers/ib/feed.py index fc273c07..adeb6361 100644 --- a/piker/brokers/ib/feed.py +++ b/piker/brokers/ib/feed.py @@ -989,7 +989,7 @@ async def open_aio_quote_stream( symbol=symbol, contract=contract, - ) as (contract, from_aio): + ) as (from_aio, contract): assert contract