我正在使用django和celery（django-celery）进行项目。我们的团队决定将所有数据访问代码(app-name)/manager.py包装在其中（不要像django这样包装到Manager中），而将代码放入（应用程序名称）/task.py中，仅处理用celery组装和执行任务（因此我们没有django在这一层的ORM依赖性）。

在我的manager.py，我有这样的事情：

def get_tag(tag_name):
    ctype = ContentType.objects.get_for_model(Photo)
    try:
        tag = Tag.objects.get(name=tag_name)
    except ObjectDoesNotExist:
        return Tag.objects.none()
    return tag

def get_tagged_photos(tag):
    ctype = ContentType.objects.get_for_model(Photo)
    return TaggedItem.objects.filter(content_type__pk=ctype.pk, tag__pk=tag.pk)

def get_tagged_photos_count(tag):
    return get_tagged_photos(tag).count()

在我的task.py中，我喜欢将它们包装成任务（然后可以使用这些任务来完成更复杂的任务），因此我编写了这个装饰器：

import manager #the module within same app containing data access functions

class mfunc_to_task(object):
    def __init__(mfunc_type='get'):
        self.mfunc_type = mfunc_type

    def __call__(self, f):
        def wrapper_f(*args, **kwargs):
            callback = kwargs.pop('callback', None)

            mfunc = getattr(manager, f.__name__)

            result = mfunc(*args, **kwargs)
            if callback:
                if self.mfunc_type == 'get':
                    subtask(callback).delay(result)
                elif self.mfunc_type == 'get_or_create':
                    subtask(callback).delay(result[0])
                else:
                    subtask(callback).delay()
            return result            

        return wrapper_f

然后（仍在task.py）：

#@task
@mfunc_to_task()
def get_tag():
    pass

#@task
@mfunc_to_task()
def get_tagged_photos():
    pass

#@task
@mfunc_to_task()
def get_tagged_photos_count():
    pass

一切正常@task。但是，在应用了该@task装饰器之后（按照celery文档的指示放到顶部），事情就开始崩溃了。显然，每次mfunc_to_task.__call__调用时，task.get_tag都会传递与相同的函数f。所以我wrapper_f每次都得到相同的结果，现在我唯一要做的就是得到一个标签。