Ipc failure while streaming#346

Merged

goodboy merged 23 commits into

masterfrom

ipc_failure_while_streaming

Jan 29, 2023

Commits on Jan 29, 2023

Handle broken mem chan on `Actor._push_result()`
goodboy
committed
Don't raise on a broken IPC-context when sending stop msg
goodboy
committed
Always set the `parent_exit: trio.Event` on exit
goodboy
committed
Ensure arbiter sockaddr type before usage
goodboy
committed
Fix uid2nursery lookup table type annot
goodboy
committed
Add WIP example of silent IPC breaks while streaming
goodboy
committed
Show tracebacks for un-shipped/propagated errors
goodboy
committed
Show more functiony syntax in ctx-cancelled log msgs
goodboy
committed
Name one-way streaming (con generators) what it is
goodboy
committed
Refine example to drop IPC mid-stream
goodboy
committed
Move example to a new `advanced_faults` egs subset dir
goodboy
committed
Wrap ex in new test, change dir helpers to use `pathlib.Path`
goodboy
committed
Adjust other examples tests to expect `pathlib` objects
goodboy
committed
Handle `mp` spawn method cases in test suite
goodboy
committed
Skip `advanced_faults/` subset in docs examples tests
goodboy
committed
Add IPC breakage on both parent and child side
goodboy
committed
Add parent vs. child cancels first cases
goodboy
committed
Add a simplified zombie lord specific process reaping test
goodboy
committed
Tweak warning msg for still-alive-after-cancelled actor
goodboy
committed
Call `MsgStream.aclose()` in `Context.open_stream.__aexit__()`
goodboy
committed
Add nooz
goodboy
committed
Bump up legacy streaming timeout a smidgen
goodboy
committed
Move result log msg up and drop else block
goodboy
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Ipc failure while streaming#346

Ipc failure while streaming#346
goodboy merged 23 commits into
masterfrom
ipc_failure_while_streaming

Commits on Jan 29, 2023

Handle broken mem chan on `Actor._push_result()`

Don't raise on a broken IPC-context when sending stop msg

Always set the `parent_exit: trio.Event` on exit

Ensure arbiter sockaddr type before usage

Fix uid2nursery lookup table type annot

Add WIP example of silent IPC breaks while streaming

Show tracebacks for un-shipped/propagated errors

Show more functiony syntax in ctx-cancelled log msgs

Name one-way streaming (con generators) what it is

Refine example to drop IPC mid-stream

Move example to a new `advanced_faults` egs subset dir

Wrap ex in new test, change dir helpers to use `pathlib.Path`

Adjust other examples tests to expect `pathlib` objects

Handle `mp` spawn method cases in test suite

Skip `advanced_faults/` subset in docs examples tests

Add IPC breakage on both parent and child side

Add parent vs. child cancels first cases

Add a simplified zombie lord specific process reaping test

Tweak warning msg for still-alive-after-cancelled actor

Call `MsgStream.aclose()` in `Context.open_stream.aexit()`

Add nooz

Bump up legacy streaming timeout a smidgen

Move result log msg up and drop else block