pool Package

test_process Module

worq.tests.pool.test_process.WorkerPool_crashed_worker_init(url)[source]
worq.tests.pool.test_process.WorkerPool_heartrate_init(url)[source]
worq.tests.pool.test_process.WorkerPool_max_worker_tasks_init(url)[source]
worq.tests.pool.test_process.WorkerPool_sigterm_init(url, tmp, logpath)[source]
worq.tests.pool.test_process.WorkerPool_worker_shutdown_on_parent_die_init(url, tmp, logpath)[source]
worq.tests.pool.test_process.discard_tasks(*args, **kwds)[source]
worq.tests.pool.test_process.force_kill_on_exit(*args, **kwds)[source]
worq.tests.pool.test_process.noop()[source]
worq.tests.pool.test_process.pid_running(pid)[source]
worq.tests.pool.test_process.printlog(*args, **kwds)[source]
worq.tests.pool.test_process.process_config(logpath, procname)[source]
worq.tests.pool.test_process.reader(*path)[source]
worq.tests.pool.test_process.start_pool(*args, **kwds)[source]
worq.tests.pool.test_process.test_WorkerPool_crashed_worker()[source]
worq.tests.pool.test_process.test_WorkerPool_heartrate()[source]
worq.tests.pool.test_process.test_WorkerPool_max_worker_tasks()[source]
worq.tests.pool.test_process.test_WorkerPool_sigterm()[source]
worq.tests.pool.test_process.test_WorkerPool_start_twice()[source]
worq.tests.pool.test_process.test_WorkerPool_worker_shutdown_on_parent_die()[source]
worq.tests.pool.test_process.touch(path, data='')[source]
worq.tests.pool.test_process.verify_shutdown(proc)[source]
worq.tests.pool.test_process.worker_pool(url, init_func, init_args, workers=1)[source]