pypushflow.concurrent.interrupt.process

Utilities to terminate process pool tasks

Functions

interrupt_task(pid)	rtype: None
task_main(fn, *args, **kwargs)
worker_initializer()