pypushflow.concurrent.interrupt.process.worker_initializer

pypushflow.concurrent.interrupt.process.worker_initializer()