events.py 文件源码

def runAsync(self, func, args, kwargs, title, success, error, errorcb=None, successcb=None):
        def runner():
            try:
                func(*args, **kwargs)
            except (Exception, exceptions.BaseError),  e:
                eco = j.errorconditionhandler.processPythonExceptionObject(e)
                if errorcb:
                    try:
                        errorcb(eco)
                    except:
                        pass
                errormsg = error + "</br> For more info check <a href='/grid/error condition?id=%s'>error</a> details" % eco.guid
                self.sendMessage(title, errormsg, 'error', hide=False)
                return
            refreshhint = self.ctx.env.get('HTTP_REFERER')
            self.sendMessage(title, success, 'success', refresh_hint=refreshhint)
            if successcb:
                successcb()
        self.sendMessage(title, 'Started')
        gevent.spawn(runner)