pypushflow.tests.concurrent.utils.assert_error_callback

pypushflow.tests.concurrent.utils.assert_error_callback(pool, name)