test_apply_async()
pypushflow.tests.concurrent.test_apply_async.error
pypushflow.tests.concurrent.test_interrupt