task_main()
pypushflow.concurrent.interrupt.process.interrupt_task
pypushflow.concurrent.interrupt.process.worker_initializer