CeleryTaskProxy

celery_task_proxy.py

class CeleryTaskProxy(object):
    """
    Method proxy to execute namespaced Celery tasks via send_task.
    """
    def __init__(self, celery, namespace):
        self._celery = celery
        self._namespace = namespace

    def __getattr__(self, attr):
        def runner(*args, **kwargs):
            task_name = "{}.{}".format(self._namespace, attr)
            return self._celery.send_task(task_name, args, kwargs)

        return runner