pypushflow.concurrent.interrupt.process.task_main

pypushflow.concurrent.interrupt.process.task_main(fn, *args, **kwargs)