pypushflow.tests.concurrent.utils.assert_error_callback

pypushflow.tests.concurrent.utils.assert_error_callback(pool, name)[source]