Module test_asyncprocess

distributed.tests.test_asyncprocess

Functions

▷ def exit(q)
source link
▷ def exit_now(rc=0)
source link
▷ def exit_with_signal(signum)
source link
▷ def feed(in_q, out_q)
source link

▶ def test_asyncprocess_child_teardown_on_parent_exit()

Check that a child process started by AsyncProcess exits if its parent exits.

The motivation is to ensure that if an AsyncProcess is created and the
creator process dies unexpectedly (e.g, via Out-of-memory SIGKILL), the
child process and resources held by it should not be leaked.

The child should monitor its parent and exit promptly if the parent exits.

[test process] -> [parent using AsyncProcess (dies)] -> [worker process]
             \                                          /
              \________ <--   child_pipe   <-- ________/

▷ def threads_info(q)
source link
▷ def wait()
source link

Distributed

Module test_asyncprocess

Functions