def execute(self, x, y):
        super(ConditionalTask, self).execute()
        if x != y:
            raise RuntimeError('Woot!')
dataset/ETHPy150Open openstack/taskflow/taskflow/tests/utils.py/ConditionalTask.execute/original