pypushflow.tests.concurrent.filter_combinations.filter_callback

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