Compare commits
2 Commits
0a2059d00f
...
fa4130aeae
| Author | SHA1 | Date |
|---|---|---|
|
|
fa4130aeae | |
|
|
14e4eb495e |
|
|
@ -586,7 +586,7 @@ async def open_price_feed(
|
|||
fh,
|
||||
instrument
|
||||
)
|
||||
) as (chan, first):
|
||||
) as (first, chan):
|
||||
yield chan
|
||||
|
||||
|
||||
|
|
@ -653,7 +653,7 @@ async def open_order_feed(
|
|||
fh,
|
||||
instrument
|
||||
)
|
||||
) as (chan, first):
|
||||
) as (first, chan):
|
||||
yield chan
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -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 (chan, first),
|
||||
) as (first, chan),
|
||||
|
||||
trionics.collapse_eg(), # loose-ify
|
||||
trio.open_nursery() as relay_tn,
|
||||
|
|
|
|||
|
|
@ -514,8 +514,8 @@ async def open_trade_event_stream(
|
|||
recv_trade_updates,
|
||||
client=client,
|
||||
) as (
|
||||
trade_event_stream,
|
||||
_, # first pushed val
|
||||
trade_event_stream,
|
||||
):
|
||||
task_status.started(trade_event_stream)
|
||||
# block forever to keep session trio-asyncio session
|
||||
|
|
|
|||
|
|
@ -989,7 +989,7 @@ async def open_aio_quote_stream(
|
|||
symbol=symbol,
|
||||
contract=contract,
|
||||
|
||||
) as (from_aio, contract):
|
||||
) as (contract, from_aio):
|
||||
|
||||
assert contract
|
||||
|
||||
|
|
|
|||
|
|
@ -203,8 +203,9 @@ pyvnc = { git = "https://github.com/regulad/pyvnc.git" }
|
|||
# xonsh = { git = 'https://github.com/xonsh/xonsh.git', branch = 'main' }
|
||||
|
||||
# XXX since, we're like, always hacking new shite all-the-time. Bp
|
||||
tractor = { git = "https://github.com/goodboy/tractor.git", branch ="main" }
|
||||
tractor = { git = "https://github.com/goodboy/tractor.git", branch ="piker_pin" }
|
||||
# tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "piker_pin" }
|
||||
# tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "main" }
|
||||
# ------ goodboy ------
|
||||
# hackin dev-envs, usually there's something new he's hackin in..
|
||||
# tractor = { path = "../tractor", editable = true }
|
||||
|
|
|
|||
4
uv.lock
4
uv.lock
|
|
@ -1034,7 +1034,7 @@ requires-dist = [
|
|||
{ name = "tomli", specifier = ">=2.0.1,<3.0.0" },
|
||||
{ name = "tomli-w", specifier = ">=1.0.0,<2.0.0" },
|
||||
{ name = "tomlkit", git = "https://github.com/pikers/tomlkit.git?branch=piker_pin" },
|
||||
{ name = "tractor", git = "https://github.com/goodboy/tractor.git?branch=main" },
|
||||
{ name = "tractor", git = "https://github.com/goodboy/tractor.git?branch=piker_pin" },
|
||||
{ name = "trio", specifier = ">=0.27" },
|
||||
{ name = "trio-typing", specifier = ">=0.10.0" },
|
||||
{ name = "trio-util", specifier = ">=0.7.0,<0.8.0" },
|
||||
|
|
@ -1676,7 +1676,7 @@ wheels = [
|
|||
[[package]]
|
||||
name = "tractor"
|
||||
version = "0.1.0a6.dev0"
|
||||
source = { git = "https://github.com/goodboy/tractor.git?branch=main#e77198bb64f0467a50e251ed140daee439752354" }
|
||||
source = { git = "https://github.com/goodboy/tractor.git?branch=piker_pin#566a17ba92469000a01fd18c709ea3e336e72796" }
|
||||
dependencies = [
|
||||
{ name = "bidict" },
|
||||
{ name = "cffi" },
|
||||
|
|
|
|||
Loading…
Reference in New Issue