def test_task_return_exception(self):
        self.mm.seek(0)
        wire.PackedMessageWriter(self.mm).string('__unknown_task__')

        msg = self._run_task(self.task)
        assert msg == 'ok'

        self.mm.seek(0)
        reader = wire.PackedMessageReader(self.mm)
        assert reader.uint8() == 0
        error_msg = reader.string()
        assert 'Traceback' in error_msg
dataset/ETHPy150Open cloudera/ibis/ibis/tests/test_tasks.py/TestTaskE2E.test_task_return_exception/original