pypushflow.tests.concurrent.filter_combinations.filter_error_callback

pypushflow.tests.concurrent.filter_combinations.filter_error_callback(pool_type, task_name, context)