assert_error_callback()
pypushflow.tests.concurrent.utils.assert_callback
pypushflow.tests.concurrent.utils.pool_context