

def test_invalid_functor(self):
    self.assertRaises(ValueError, task.ReduceFunctorTask, 2, requires=5)
    self.assertRaises(ValueError, task.ReduceFunctorTask, (lambda : None), requires=5)
    self.assertRaises(ValueError, task.ReduceFunctorTask, (lambda x: None), requires=5)

dataset/ETHPy150Open openstack/taskflow/taskflow/tests/unit/test_task.py ReduceFunctorTaskTest.test_invalid_functor/original