piker

Author	SHA1	Message	Date
Nelson Torres	12e371b027	uv migration	2025-02-12 11:19:34 -03:00
goodboy	014bd58db4	Merge pull request 'go_httpx' (#2 ) from go_httpx into gitea_feats Landed-in: #2	2025-02-12 13:01:19 +00:00
Tyler Goodlet	844544ed8e	Port binance to `httpx` Like other backends use the `AsyncClient` for all venue specific client-sessions but change to allocating them inside `get_client()` using an `AsyncExitStack` and inserting directly in the `Client.venue_sesh: dict` table during init. Supporting impl tweaks: - remove most of the API client session building logic and instead make `Client.__init__()` take in a `venue_sessions: dict` (set it to `.venue_sesh`) and `conf: dict`, instead opting to do the http client configuration inside `get_client()` since all that code only needs to be run once. \|_load config inside `get_client()` once. \|_move session token creation into a new util func `init_api_keys()` and also call it from `get_client()` factory; toss in an ex. toml section config to the doc string. - define `_venue_urls: dict[str, str]` (content taken from old static `.venue_sesh` dict) at module level and feed them as `base_url: str` inputs to the client create loop. - adjust all call sigs in httpx-sesh-using methods, namely just `._api()`. - do a `.exch_info()` call in `get_client()` to cache the symbology set. Unrelated changes for various other outstanding buggers: - to get futures feeds correctly loading when selected from search (like 'XMRUSDT.USDTM.PERP'), expect a `MktPair` input to `Client.bars()` such that the exact venue-key can be looked up (via a new `.pair2venuekey()` meth) and then passed to `._api()`. - adjust `.broker.open_trade_dialog()` to failover to paper engine when there's no `api_key` key set for the `subconf` venue-key.	2025-02-11 16:27:28 -05:00
Nelson Torres	f479252d26	Added note to exception when missing field in SpotPair class	2025-02-11 16:27:28 -05:00
Nelson Torres	033ef2e35e	Added new fields to SpotPair class in venues	2025-02-11 16:27:28 -05:00
Tyler Goodlet	2cdece244c	binance: raise `NoData` on null hist arrays Like we do with other history backends to indicate lack of a data set. This avoids any raise that will will bring down the backloader task with some downstream error. Raise a `ValueError` on no time index for now.	2025-02-11 16:27:28 -05:00
Tyler Goodlet	018694bbdb	Woops, `data` can be an empty list XD	2025-02-11 16:27:28 -05:00
Tyler Goodlet	128a2d507f	Woops, fix missing `api_url` ref in error log	2025-02-11 16:27:28 -05:00
Tyler Goodlet	430650a6a7	Change type-annots to use `httpx.Response`	2025-02-11 16:27:28 -05:00
Tyler Goodlet	1da3cf5698	Port `kucoin` backend to `httpx`	2025-02-11 16:27:28 -05:00
Tyler Goodlet	a348603fc4	Port `kraken` backend to `httpx`	2025-02-11 16:27:28 -05:00
goodboy	86047824d8	Merge pull request '`.brokers.ib` random fixes-n-improvements from various other dev branches..' (#27 ) from ib_refinements into gitea_feats Merged-in: #27	2025-02-11 21:26:20 +00:00
Tyler Goodlet	cb92abbc38	ib: add connect status info emit	2025-02-11 14:56:17 -05:00
Tyler Goodlet	70332e375b	ib: `.api` mod and log-fmt cleaning About time we tidy'd a buncha status logging in this backend.. particularly for boot-up where there's lots of client-try-connect poll looping with account detection from the user config. `.api.Client` pprint and logging fmt improvements: - add `Client.__repr__()` which shows the minimally useful set of info from the underlying `.ib: IB` as well as a new `.acnts: list[str]` of the account aliases defined in the user's `brokers.toml`. - mk `.bars()` define a comprehensive `query_info: str` with all the request deats but only display if there's a problem with the response data. - mk `.get_config()` report both the config file path and the acnt aliases (NOT the actual account #s). - move all `.load_aio_clients()` client poll loop requests do `log.runtime()` statuses, only falling through to a `.warning()` when the loop fails to connect the client to the spec-ed API-gw addr, and \|_ don't allow loading accounts for which the user has not defined an alias in `brokers.toml::[ib]`; raise a value-error in such cases with a message indicating how to mod the config. \|_ only `log.info()` about acnts if some were loaded.. Other mod logging de-noising: - better status fmting in `.symbols.open_symbol_search()` with `repr(Client)`. - for `.feed.stream_quotes()` first quote reporting use `.runtime()`.	2025-02-11 14:56:17 -05:00
Tyler Goodlet	4940aabe05	ib: warn about mkt precision cuckups that `Contract`s clearly deliver wrong..	2025-02-11 14:56:17 -05:00
Tyler Goodlet	4f9998e9fb	ib: mask out trade and vlm rates for now	2025-02-11 14:56:17 -05:00
Tyler Goodlet	c92a236196	ib: more trade record edge case handling - timestamps came as `'date'`-keyed from 2022 and before but now are `'datetime'`.. - some symbols seem to have no commission field, so handle that.. - when no `'price'` field found return `None` from `norm_trade()`. - add a warn log on mid-fill commission updates.	2025-02-11 14:56:17 -05:00
goodboy	e4cd1f85f6	Merge pull request 'pyqt6' (#3 ) from pyqt6 into gitea_feats Reviewed-on: #3 (well by fomo anyway..)	2025-02-11 17:25:03 +00:00

1 changed files with 9 additions and 1 deletions

									
										10

piker/brokers/ib/api.py

										View File
									
					@ -1250,6 +1250,12 @@ async def load_aio_clients(

					        for i in range(connect_retries):

					        for i in range(connect_retries):

					            try:

					            try:

					                log.info(

					                    'Trying `ib_async` connect\n'

					                    f'{host}: {port}\n'

					                    f'clientId: {client_id}\n'

					                    f'timeout: {connect_timeout}\n'

					                )

					                await ib.connectAsync(

					                await ib.connectAsync(

					                    host,

					                    host,

					                    port,

					                    port,

					@ -1367,7 +1373,9 @@ async def load_clients_for_trio(

					    a ``tractor.to_asyncio.open_channel_from()``.

					    a ``tractor.to_asyncio.open_channel_from()``.

					    '''

					    '''

					    async with load_aio_clients() as accts2clients:

					    async with load_aio_clients(

					        disconnect_on_exit=False,

					    ) as accts2clients:

					        to_trio.send_nowait(accts2clients)

					        to_trio.send_nowait(accts2clients)

Compare commits

18 Commits

76b5547c2d ... 12e371b027

10

piker/brokers/ib/api.py

View File

Compare commits

18 Commits 76b5547c2d ... 12e371b027

10 piker/brokers/ib/api.py Unescape Escape View File

18 Commits

76b5547c2d ... 12e371b027

10

piker/brokers/ib/api.py

View File