Comparing e4d6f0940d..3e4e7c889b - piker - Pikers Dev

..

Author	SHA1	Message	Date
Tyler Goodlet	3e4e7c889b	Allow ledger passes to ignore (symcache) unknown fqmes For example in the paper-eng, if you have a backend that doesn't fully support a symcache (yet) it's handy to be able to ignore processing other paper-eng txns when all you care about at the moment is the simulated symbol. NOTE, that currently this will still result in a key-error when you load more then one mkt with the paper engine (for which the backend does not have the symcache implemented) since no fqme ad-hoc query was made for the 2nd symbol (and i'm not sure we should support that kinda hackery over just encouraging the sym-cache being added?). Def needs a little more thought depending on how many backends are never going to be able to (easily) support caching..	2025-01-29 12:56:11 -03:00
Tyler Goodlet	afa5655af7	.clearing._ems: Don't require `first_quote['last']` Instead just check for the field (which i'm not huge on the key-name for anyway) and if not found get the "last price" from the real-time shm buffer's latest 'close' sample. Unrelatedly, use a `subs.copy()` in the `Router.client_broadcast()` loop such that if a `client_stream` is popped on connection failure, we don't RTE for the "size changed on iteration".	2025-01-29 12:56:11 -03:00
Tyler Goodlet	3ebbfcb9ca	`kucoin`: repair live quotes streaming.. This must have broke at some point during the new `MktPair` and thus `.fqme: str` updates; mas-o-menos the symbol key in the quote-msg-`dict` was NOT set to the `MktPair.bs_fqme: str` value and thus wasn't being processed by the downstream sampling and feed subsys. So fix that as well as a few other refinements, - set the `topic: mkt.bs_fqme` in quote msgs obvi. - drop the "wait for first clearing vlm" quote poll loop; going to fix the sampler to handle a `first_quote` without a `'last'` key. - add some typing around calls to `get_mkt_info()`. - rename `stream_messages()` -> `iter_normed_quotes()`.	2025-01-29 12:56:11 -03:00
Nelson Torres	85377a5dc3	Deleted settlePlan field from binance FutesPair.	2025-01-29 12:56:11 -03:00
Nelson Torres	d512037ed4	Added missing fields for kucoin. feeCategory, makerFeeCoefficient, takerFeeCoefficient and st.	2025-01-29 12:56:11 -03:00
Nelson Torres	ec2203168a	`default.nix` is created with required nixos deps "wiring" `pyproject.toml` update to use pikers.dev/goodboy/tractor.git, branch: `aio_abandons`.	2025-01-29 00:34:25 -03:00
Nelson Torres	69b1bb57ea	Updated tractor method name.	2025-01-29 00:17:36 -03:00
Tyler Goodlet	1f2755ee36	Drop `.cancel_actor()` from `maybe_spawn_daemon()` Since `tractor`'s new and improved inter-actor cancellation semantics are much more pedantic, AND bc we use the `ServiceMngr` for spawning service actors on-demand, the caller of `maybe_spawn_daemon()` should NEVER conduct a so called "out of band" `Actor`-runtime cancel request since this is precisely the job of our `ServiceMngr` XD Add a super in depth note explaining the underlying issue and adding a todo list of how we should prolly augment `tractor` to make such cases easier to grok and fix in the future!	2025-01-29 00:17:36 -03:00
Tyler Goodlet	ff171af168	Prep service mngr for move to `tractor.hilevel` Given it's a fairly simple yet useful abstraction, it makes sense to offer this sub-sys alongside the core `tractor` runtime lib. Without going into extreme detail on the impl changes (it'll come in the commit that moves to the other repo) here is the high level summary: ------ - ------ - rename `Services` -> `ServiceMngr` and use an factory `@acm` to guarantee a single-instance-per-actor using a niche approach for a singleton object using a default keyword-arg B) - the mod level `open_service_mngr()` and `get_service_mngr()` are the new allocation/access API. - add a `ServiceMngr.start_service()` method which does the work of both spawning a new subactor (for the daemon) and uses its portal to start the mngr side supervision task. - open actor/task nurseries inside the `@acm` allocator. Adjust other dependent subsystems to match: ------ - ------ - use `open_service_mngr()` when first allocated in `open_pikerd()`. - use `get_service_mngr()` instead of importing the class ref inside `.service.maybe_spawn_daemon()`, `.brokers._daemon.spawn_brokerd()` and `.data._sampling.spawn_samplerd()` using a `partial` to pack in the endpoint ctx kwargs (unpacked inside `.start_service()` XD).	2025-01-29 00:17:36 -03:00
Tyler Goodlet	aa4a89451a	Lel, forgot to add a `SPOT` venue for `binance`..	2025-01-29 00:17:36 -03:00
Tyler Goodlet	a461fcc3e3	Mask no-data pause-point, add perps to sig. Was orig for debugging an issue with `kucoin` i think but definitely shouldn't be left in XD Also add `'perpetual_future'` to `start_backfill()` input literal set.	2025-01-29 00:17:36 -03:00

Diff Content Not Available