pypushflow.tests.concurrent.utils.assert_callback

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