goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 8 Packages Projects Releases Wiki Activity

Commit Graph

  • efd11f7d74
         Trying to make full suite pass with uds #17 structural_dynamics_of_flow Guillermo Rodriguez 2025-03-23 02:18:01 -0300
  • 76cee99fc2
         Finally switch to using address protocol in all runtime Guillermo Rodriguez 2025-03-23 00:14:04 -0300
  • 5f50206d84
         Add root and random addr getters on MsgTransport type Guillermo Rodriguez 2025-03-22 16:17:50 -0300
  • a47a7a39b1
         Starting to make tractor.ipc.Channel work with multiple MsgTransports Guillermo Rodriguez 2025-03-22 15:29:48 -0300
  • bab265b2d8
         Important RingBuffBytesSender fix on non batched mode! & downgrade nix-shell python to lowest supported #10 one_ring_to_rule_them_all Guillermo Rodriguez 2025-03-22 16:54:00 -0300
  • 010874bed5
         Catch trio cancellation on RingBuffReceiver bg eof listener task, add batched mode to RingBuffBytesSender Guillermo Rodriguez 2025-03-20 21:12:06 -0300
  • ea010ab46a
         Add direct read method on EventFD Type hint all ctx managers in _ringbuf.py Remove unnecesary send lock on ring chan sender Handle EOF on ring chan receiver Rename ringbuf tests to make it less redundant Guillermo Rodriguez 2025-03-18 22:48:12 -0300
  • be7fc89ae9
         Add direct ctx managers for RB channels Guillermo Rodriguez 2025-03-18 13:47:41 -0300
  • 2a9a78651b
         Improve test_ringbuf test, drop MsgTransport ring buf impl for now in favour of a trio.abc.Channel[bytes] impl, add docstrings Guillermo Rodriguez 2025-03-18 13:19:40 -0300
  • be818a720a
         Switch `tractor.ipc.MsgTransport.stream` type to `trio.abc.Stream` Add EOF signaling mechanism Support proper `receive_some` end of stream semantics Add StapledStream non-ipc test Create MsgpackRBStream similar to MsgpackTCPStream for buffered whole-msg reads Add EventFD.read cancellation on EventFD.close mechanism using cancel scope Add test for eventfd cancellation Improve and add docstrings Guillermo Rodriguez 2025-03-16 23:57:26 -0300
  • ba353bf46f
         Better encapsulate RingBuff ctx managment methods and support non ipc usage Add trio.StrictFIFOLock on sender.send_all Support max_bytes argument on receive_some, keep track of write_ptr on receiver Add max_bytes receive test test_ringbuf_max_bytes Add docstrings to all ringbuf tests Remove EFD_NONBLOCK support, not necesary anymore since we can use abandon_on_cancel=True on trio.to_thread.run_sync Close eventfd's after usage on open_ringbuf Guillermo Rodriguez 2025-03-16 17:50:13 -0300
  • 9b2161506f
         Break out transport protocol and tcp specifics into their own submodules under tractor.ipc Guillermo Rodriguez 2025-03-16 14:14:32 -0300
  • 6b155849b7
         Add buf_size to RBToken and add sender cancel test, move disable_mantracker to its own _mp_bs module Guillermo Rodriguez 2025-03-14 00:25:10 -0300
  • 59c8c7bfe3
         Make ring buf api use pickle-able RBToken Guillermo Rodriguez 2025-03-13 23:12:20 -0300
  • 6ac6fd56c0
         Address some of fomo\'s comments Guillermo Rodriguez 2025-03-13 22:47:45 -0300
  • f799e9ac51
         Handle cancelation on EventFD.read Guillermo Rodriguez 2025-03-13 22:43:02 -0300
  • 9980bb2bd0
         Add module headers and fix spacing on tractor._ipc._linux Guillermo Rodriguez 2025-03-13 21:25:50 -0300
  • 8de9ab291e
         Move RingBuffSender|Receiver to its own tractor.ipc._ringbuf module Guillermo Rodriguez 2025-03-13 21:15:16 -0300
  • 1a83626f26
         Move linux specifics from tractor.ipc._shm into tractor.ipc._linux Guillermo Rodriguez 2025-03-13 21:10:23 -0300
  • 6b4d08d030
         Move tractor._shm to tractor.ipc._shm Guillermo Rodriguez 2025-03-13 20:59:14 -0300
  • 7b8b9d6805
         move tractor._ipc.py into tractor.ipc._chan.py Guillermo Rodriguez 2025-03-13 20:41:30 -0300
  • 5afe0a0264
         General improvements Guillermo Rodriguez 2025-03-13 20:17:04 -0300
  • eeb9a7d61b
         IPC ring bug impl with async read Guillermo Rodriguez 2025-03-12 16:13:40 -0300
  • 5cee222353 Updates from latest `piker.data._sharedmem` changes #15 shm_apis Tyler Goodlet 2023-06-22 17:16:17 -0400
  • 8ebb1f09de Pass `str` dtype for `use_str` case Tyler Goodlet 2022-10-20 16:08:28 -0400
  • 2683a7f33a Allocate size-specced "empty" sequence from default values by type Tyler Goodlet 2022-10-19 14:20:50 -0400
  • 255209f881 Mod define `_USE_POSIX`, add a of of todos Tyler Goodlet 2022-10-18 16:28:57 -0400
  • 9a0d529b18 Parametrize rw test with variable frame sizes Tyler Goodlet 2022-10-18 11:01:30 -0400
  • 1c441b0986 Add `ShmList` slice support in `.__getitem__()` Tyler Goodlet 2022-10-18 11:01:02 -0400
  • afbdb50a30 Rename token type to `NDToken` in the style of `nptyping` Tyler Goodlet 2022-10-17 17:21:14 -0400
  • e46033cbe7 Don't require runtime (for now), type annot fixing Tyler Goodlet 2022-10-17 15:13:58 -0400
  • c932bb5911 Add repetitive attach to existing segment test Tyler Goodlet 2022-10-17 15:13:05 -0400
  • 33482d8f41 Add initial readers-writer shm list tests Tyler Goodlet 2022-10-16 18:16:58 -0400
  • 7ae194baed Add `ShmList` wrapping the stdlib's `ShareableList` Tyler Goodlet 2022-10-16 18:06:07 -0400
  • ef7ca49e9b Initial module import from `piker.data._sharemem` Tyler Goodlet 2022-10-15 16:35:32 -0400
  • fde681fa19 Merge pull request 'Extension types support via msgspec.Encoder/Decoder hooks' (#19) from ext_type_plds into main main Tyler Goodlet 2025-03-27 17:43:43 -0400
  • efcf81bcad Add `.runtime()`-emit to `._invoke()` to report final result msg in the child ext_type_plds Tyler Goodlet 2025-03-12 16:41:42 -0400
  • 3988ea69f5 Add `MsgStream._stop_msg` use new `PldRx` API Tyler Goodlet 2025-03-12 16:24:39 -0400
  • 8bd4490cad Add `Context._outcome_msg` use new `PldRx` API Tyler Goodlet 2025-03-12 15:03:55 -0400
  • 622f840dfd Slight `PldRx` rework to simplify Tyler Goodlet 2025-03-12 13:49:58 -0400
  • 8ba315e60c Rename ext-types with `msgspec` suite module Tyler Goodlet 2025-03-12 13:47:53 -0400
  • 80f20b35b1 Complete rename to parent->child IPC ctx peers Tyler Goodlet 2025-03-12 13:15:48 -0400
  • 9ec37dd13f Fix msg-draining on `parent_never_opened_stream`! Tyler Goodlet 2025-03-11 14:31:53 -0400
  • 9be76b1dda Extend ctx semantics suite for streaming edge cases! Tyler Goodlet 2025-03-11 14:04:55 -0400
  • 31f88b59f4 Deliver a `MaybeBoxedError` from `.expect_ctxc()` Tyler Goodlet 2025-03-10 18:17:31 -0400
  • 155d581fa2 Avoid attr-err when `._ipc_msg==None` Tyler Goodlet 2025-03-10 11:17:46 -0400
  • a810f6c8f6 Facepalm, fix logic misstep on child side Tyler Goodlet 2025-03-08 23:58:31 -0500
  • 83b9dc3c62 Rework IPC-using `test_caps_basesd_msging` tests Tyler Goodlet 2025-03-08 15:52:13 -0500
  • f152a20025 Raise RTE from `limit_plds()` on no `curr_ctx` Tyler Goodlet 2025-03-08 15:50:14 -0500
  • 1ea8254ae3 Offer a `mods: list` to `dec_type_union()`; drop importing this-mod Tyler Goodlet 2025-03-08 15:49:21 -0500
  • 8ed890f892 Tweak type-error messages for when `ext_types` is missing Tyler Goodlet 2025-03-08 15:48:18 -0500
  • d4e6f2b8dc Move `Union` serializers to new `msg.` mod Tyler Goodlet 2025-03-07 14:38:22 -0500
  • 64fe767647 Finally get type-extended `msgspec` fields workinn Tyler Goodlet 2025-03-07 14:13:36 -0500
  • aca015f1c2 Mask top level import of `.hilevel` Tyler Goodlet 2025-03-16 17:20:20 -0400
  • 818cd8535f Support `ctx: UnionType` annots for `@tractor.context` eps Tyler Goodlet 2024-12-11 22:22:26 -0500
  • c362603d15 Add `debug_mode: bool` control to task mngr #23 oco_supervisor_prototype Tyler Goodlet 2023-05-19 15:51:47 -0400
  • c169417085 Go all in on "task manager" naming Tyler Goodlet 2023-05-19 14:49:10 -0400
  • 9bbe7ca945 More refinements and proper typing Tyler Goodlet 2023-05-19 14:23:22 -0400
  • c32520cb11 Ensure user-allocated cancel scope just works! Tyler Goodlet 2023-05-19 14:03:07 -0400
  • 3613b6019c Facepalm, don't pass in unecessary cancel scope Tyler Goodlet 2023-05-19 13:34:00 -0400
  • 7b4accf53f Do renaming, implement lowlevel `Outcome` sending Tyler Goodlet 2023-05-19 13:13:21 -0400
  • 5e25cf7399 Alias to `@acm` in broadcaster mod Tyler Goodlet 2023-05-17 15:27:29 -0400
  • 78f51a3fd8 Initial prototype for a one-cancels-one style supervisor, nursery thing.. Tyler Goodlet 2023-05-17 14:31:06 -0400
  • 0279bb3311 Use shorthand nursery var-names per convention in codebase Tyler Goodlet 2024-12-11 20:26:13 -0500
  • 106dca531a Better separate service tasks vs. ctxs via methods Tyler Goodlet 2024-12-11 14:24:49 -0500
  • dfa2914c1d Mv over `ServiceMngr` from `piker` with mods Tyler Goodlet 2024-12-11 12:38:35 -0500
  • 896b2c73f4 Initial idea-notes dump and @singleton factory idea from `trio`-gitter Tyler Goodlet 2024-11-27 20:29:16 -0500
  • d1f1cd3474 Use shorthand nursery var-names per convention in codebase #12 hilevel_serman Tyler Goodlet 2024-12-11 20:26:13 -0500
  • 908214ce5c Better separate service tasks vs. ctxs via methods Tyler Goodlet 2024-12-11 14:24:49 -0500
  • 8cc9025db9 Mv over `ServiceMngr` from `piker` with mods Tyler Goodlet 2024-12-11 12:38:35 -0500
  • 1128181c64 Initial idea-notes dump and @singleton factory idea from `trio`-gitter Tyler Goodlet 2024-11-27 20:29:16 -0500
  • eb12029372 Mask top level import of `.hilevel` #19 Tyler Goodlet 2025-03-16 17:20:20 -0400
  • 27a97e8b1c Add `.runtime()`-emit to `._invoke()` to report final result msg in the child Tyler Goodlet 2025-03-12 16:41:42 -0400
  • 8921443503 Add `MsgStream._stop_msg` use new `PldRx` API Tyler Goodlet 2025-03-12 16:24:39 -0400
  • c8dd4a3452 Add `Context._outcome_msg` use new `PldRx` API Tyler Goodlet 2025-03-12 15:03:55 -0400
  • 7b43bd9f25 Slight `PldRx` rework to simplify Tyler Goodlet 2025-03-12 13:49:58 -0400
  • de8d8afc41 Rename ext-types with `msgspec` suite module Tyler Goodlet 2025-03-12 13:47:53 -0400
  • 9b89d79ef6 Complete rename to parent->child IPC ctx peers Tyler Goodlet 2025-03-12 13:15:48 -0400
  • 99958cc727 Fix msg-draining on `parent_never_opened_stream`! Tyler Goodlet 2025-03-11 14:31:53 -0400
  • 4e5742a056 Extend ctx semantics suite for streaming edge cases! Tyler Goodlet 2025-03-11 14:04:55 -0400
  • 3e1d18497f Deliver a `MaybeBoxedError` from `.expect_ctxc()` Tyler Goodlet 2025-03-10 18:17:31 -0400
  • f3b10a8032 Support `ctx: UnionType` annots for `@tractor.context` eps Tyler Goodlet 2024-12-11 22:22:26 -0500
  • 305e1d0347 Avoid attr-err when `._ipc_msg==None` Tyler Goodlet 2025-03-10 11:17:46 -0400
  • 80fa61af61 Facepalm, fix logic misstep on child side Tyler Goodlet 2025-03-08 23:58:31 -0500
  • 048a232a6e Rework IPC-using `test_caps_basesd_msging` tests Tyler Goodlet 2025-03-08 15:52:13 -0500
  • 337385762b Raise RTE from `limit_plds()` on no `curr_ctx` Tyler Goodlet 2025-03-08 15:50:14 -0500
  • fbb8c7ecd0 Offer a `mods: list` to `dec_type_union()`; drop importing this-mod Tyler Goodlet 2025-03-08 15:49:21 -0500
  • f8cc034630 Tweak type-error messages for when `ext_types` is missing Tyler Goodlet 2025-03-08 15:48:18 -0500
  • 56d0f10195 Move `Union` serializers to new `msg.` mod Tyler Goodlet 2025-03-07 14:38:22 -0500
  • 49aeae4150 Finally get type-extended `msgspec` fields workinn Tyler Goodlet 2025-03-07 14:13:36 -0500
  • 1e86722357 Merge pull request 'Python 3.13 support' (#18) from py313_support into main goodboy 2025-03-27 19:50:43 +0000
  • eda48c8021 Move bp to-match-comments on same line for py3.13 #18 py313_support Tyler Goodlet 2025-03-25 12:54:12 -0400
  • ceda1e466d Drop explicit `tabcompleter` dep, `pdpp` already sub-depends on it? Tyler Goodlet 2025-03-24 21:43:54 -0400
  • d14d29ae8c Bump up to `pytest>=8.3.5` to match "GH actions" Tyler Goodlet 2025-03-19 10:02:05 -0400
  • f068782e74 Bump to `msgspec>=0.19.0` for py 3.13 support! Tyler Goodlet 2025-03-10 11:51:24 -0400
  • 84b04639f8 Bind another `_bexc` for debuggin Tyler Goodlet 2025-03-05 12:39:16 -0500
  • 4aa7e8c022 Unpack errors from `pdb.bdb` Tyler Goodlet 2025-03-05 09:49:13 -0500
  • b46a886449 Show frames when decode is handed bad input Tyler Goodlet 2025-03-04 13:54:46 -0500
  • a26f817ed1 Another loosie in the trioisms suite Tyler Goodlet 2025-03-03 18:55:02 -0500
  • 2d18e6a4be Match `maybe_open_crash_handler()` to non-maybe version Tyler Goodlet 2025-03-03 18:53:13 -0500