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