queue_domain.py 文件源码

def queue_domain_process(self):
        try:
            queue_results = lib_db.queue_domains__process(self.request.api_context)
            if self.request.matched_route.name == 'admin:queue_domains:process.json':
                return {'result': 'success',
                        }
            return HTTPFound("%s/queue-domains?processed=1" % self.request.registry.settings['admin_prefix'])
        except (lib_errors.DisplayableError, lib_errors.DomainVerificationError) as e:
            # return, don't raise
            # we still commit the bookkeeping
            if self.request.matched_route.name == 'admin:queue_domains:process.json':
                return {'result': 'error',
                        'error': e.message,
                        }
            return HTTPFound("%s/queue-domains?processed=0&error=%s" % (self.request.registry.settings['admin_prefix'], e.message))
        except Exception as e:
            transaction.abort()
            if self.request.matched_route.name == 'admin:queue_domains:process.json':
                return {'result': 'error',
                        'error': e.message,
                        }
            raise

    # - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -