pikers
/
piker
3
1
Fork 0
Code Issues 8 Pull Requests 13 Packages Projects Releases Wiki Activity

stop_is_oec: expect trio.EndOfChannel as graceful stream shutdown #37

Open
goodboy wants to merge 5 commits from stop_is_oec into jsonrpc_err_in_rent
pull from: stop_is_oec
merge into: pikers:jsonrpc_err_in_rent
Conversation 1 Commits 5 Files Changed 2
goodboy commented 2025-02-20 16:32:25 +00:00
Owner

This should likely be synced with tractor’s new typed-IPC-msging either via dev branch or (ideally) a release!

Change .data._sampling broadcast error handling to include trio.EndOfChannel in the Sampler.bcast_errors: set since a tractor.MsgStream termination msg (Stop) now instead translates to that raised in task.

The main purpose here is to avoid crashing the sampler broadcast task in such graceful peer-disconnect conditions.

This should likely be synced with `tractor`'s new [typed-IPC-msging](https://pikers.dev/goodboy/tractor/pulls/7) either via dev branch or (ideally) a release! --- Change `.data._sampling` broadcast error handling to include `trio.EndOfChannel` in the `Sampler.bcast_errors: set` since a `tractor.MsgStream` termination msg (`Stop`) now instead translates to that raised in task. The main purpose here is to avoid crashing the sampler broadcast task in such graceful peer-disconnect conditions.
goodboy added 3 commits 2025-02-20 16:32:25 +00:00
6e495511ff Suppress `trio.EndOfChannel`s raised by remote peer 
Since now `tractor` will raise this native `trio`-exc translated from
a `Stop` msg when the peer gracefully terminates a `tractor.MsgStream`.
Just `info()` log in such cases versus continuing to warn for the
others.
a795108041 Group bcast errors as `Sampler.bcast_errors` 
A new class var `tuple[Exception]` such that the err set can be reffed
externally as needed for catching other similar pub-sub/IPC failures in
other (related) real-time sub-systems.

Also added some now-masked logging for debugging live-feed stream reading
issues that should ONLY be used for debugging since they'll greatly
degrade HFT perf. Used the new `log.mk_repr()` stuff (that one day we
should prolly pull from `modden` as a dep) for pretty console emissions.
389c746223 Catch using `Sampler.bcast_errors` where possible 
In all other possible IPC disconnect handling blocks. Also more
comprehensive typing throughout `uniform_rate_send()`.
goodboy force-pushed stop_is_oec from 389c746223 to 49841f5b91 2025-02-21 21:25:07 +00:00 Compare
goodboy changed title from stop_is_oec: expect `trio.EndOfChannel` as grace stream shutdown to stop_is_oec: expect `trio.EndOfChannel` as graceful stream shutdown 2025-02-21 22:12:33 +00:00
goodboy commented 2025-04-24 14:48:41 +00:00
Poster
Owner

The commit 3ff0a8674 from the branch decimal_prices_thru_ems should be cherried to this as well

The commit 3ff0a8674 from the branch `decimal_prices_thru_ems` should be cherried to this as well
This pull request can be merged automatically.
You are not authorized to merge this pull request.
You can also view command line instructions.

Step 1:

From your project repository, check out a new branch and test the changes.
git checkout -b stop_is_oec jsonrpc_err_in_rent
git pull origin stop_is_oec

Step 2:

Merge the changes and update on Gitea.
git checkout jsonrpc_err_in_rent
git merge --no-ff stop_is_oec
git push origin jsonrpc_err_in_rent
Sign in to join this conversation.
Reviewers
No reviewers
Labels
Clear labels
No items
No Label
Milestone
Clear milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
No Assignees
1 Participants
Notifications
Due Date
The due date is invalid or out of range. Please use the format 'yyyy-mm-dd'.

No due date set.

Dependencies

No dependencies set.

Reference: pikers/piker#37
There is no content yet.
Delete Branch "stop_is_oec"

Deleting a branch is permanent. Although the deleted branch may exist for a short time before cleaning up, in most cases it CANNOT be undone. Continue?