def get_task_class(self, klass_str):
        klass = self._registry.get(klass_str)

        if not klass:
            raise QueueException('%s not found in TaskRegistry' % klass_str)

        return klass
dataset/ETHPy150Open coleifer/huey/huey/registry.py/TaskRegistry.get_task_class/original