executor.py 文件源码

def _process(self, func, args, kwargs, request, response):
        start_sig = blinker.signal('BeforeFunctionExecute')
        start_sig.send(request)

        if not self.auth_func(request, func):
            raise Unauthorized

        if self.thrift_wrapper:
            return self.thrift_wrapper(func)(*args, **kwargs)
        return self._http_wrapper(data=func(*args, **kwargs))