pypushflow.tests.concurrent.utils.assert_callback

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