pypushflow.concurrent.interrupt.process# Utilities to terminate process pool tasks Functions interrupt_task(pid) task_main(fn, *args, **kwargs) worker_initializer()