celery/celery/concurrency/__init__.py

from __future__ import absolute_import

from ..utils import get_cls_by_name

ALIASES = {
    "processes": "celery.concurrency.processes.TaskPool",
    "eventlet": "celery.concurrency.eventlet.TaskPool",
    "gevent": "celery.concurrency.gevent.TaskPool",
    "threads": "celery.concurrency.threads.TaskPool",
    "solo": "celery.concurrency.solo.TaskPool",
}


def get_implementation(cls):
    return get_cls_by_name(cls, ALIASES)