From 417cf0a1a61a4f39144a20c07817b8568b593e4b Mon Sep 17 00:00:00 2001
From: zhangbailin <zhangbailin@inspur.com>
Date: Wed, 11 Nov 2020 08:56:17 +0000
Subject: [PATCH] Add pep8 job for venus

Add openstack-python-jobs templete to have a check with pep8 job.

Change-Id: Ifc869f68141305919304e0d7af1ca66b7b2dd1ca
---
 .zuul.yaml                  | 8 +++++++-
 venus/api/extensions.py     | 9 +++++++--
 venus/api/openstack/wsgi.py | 6 ++++--
 venus/service.py            | 9 ++-------
 4 files changed, 20 insertions(+), 12 deletions(-)

diff --git a/.zuul.yaml b/.zuul.yaml
index e7c200a..9f89978 100644
--- a/.zuul.yaml
+++ b/.zuul.yaml
@@ -1,3 +1,9 @@
 - project:
     templates:
-      - noop-jobs
+      - openstack-python-jobs
+    check:
+      jobs:
+        - openstack-tox-pep8
+    gate:
+      jobs:
+        - openstack-tox-pep8
diff --git a/venus/api/extensions.py b/venus/api/extensions.py
index 71c7273..401717e 100644
--- a/venus/api/extensions.py
+++ b/venus/api/extensions.py
@@ -372,14 +372,19 @@ def load_standard_extensions(ext_mgr, logger, path, package, ext_list=None):
 
 def extension_authorizer(api_name, extension_name):
     def authorize(context, target=None, action=None):
-        if target is None:
+        """if target is None:
             target = {'project_id': context.project_id,
                       'user_id': context.user_id}
         if action is None:
             act = '%s_extension:%s' % (api_name, extension_name)
         else:
             act = '%s_extension:%s:%s' % (api_name, extension_name, action)
-        #venus.policy.enforce(context, act, target)
+        # venus.policy.enforce(context, act, target)
+
+        """
+
+        pass
+
     return authorize
 
 
diff --git a/venus/api/openstack/wsgi.py b/venus/api/openstack/wsgi.py
index 21c2e19..ef01e36 100644
--- a/venus/api/openstack/wsgi.py
+++ b/venus/api/openstack/wsgi.py
@@ -29,7 +29,6 @@ from oslo_utils import excutils
 from venus import exception
 from venus import i18n
 from venus.i18n import _, _LE, _LI
-from venus.objects import base as objects_base
 from venus import utils
 from venus.wsgi import common as wsgi
 
@@ -66,7 +65,7 @@ def wrap_check_policy(func):
 
 
 def check_policy(context, action, target_obj=None):
-    target = {
+    """target = {
         'project_id': context.project_id,
         'user_id': context.user_id,
     }
@@ -78,6 +77,9 @@ def check_policy(context, action, target_obj=None):
         target.update(target_obj or {})
     _action = 'venus:%s' % action
     #venus.policy.enforce(context, _action, target)
+    """
+
+    pass
 
 
 class Request(webob.Request):
diff --git a/venus/service.py b/venus/service.py
index 7125952..f6f1f04 100644
--- a/venus/service.py
+++ b/venus/service.py
@@ -22,7 +22,6 @@ import random
 from oslo_concurrency import processutils
 from oslo_config import cfg
 from oslo_log import log as logging
-import oslo_messaging as messaging
 from oslo_service import loopingcall
 from oslo_service import service
 from oslo_utils import importutils
@@ -33,7 +32,6 @@ import osprofiler.web
 from venus import context
 from venus import exception
 from venus.i18n import _, _LI, _LW
-from venus.objects import base as objects_base
 from venus import version
 from venus.wsgi import common as wsgi_common
 from venus.wsgi import eventlet_server as wsgi
@@ -101,8 +99,6 @@ class Service(service.Service):
                  *args, **kwargs):
         super(Service, self).__init__()
 
-
-
         self.host = host
         self.binary = binary
         self.topic = topic
@@ -129,11 +125,10 @@ class Service(service.Service):
         self.manager.init_host()
         LOG.debug("Creating RPC server for service %s", self.topic)
 
-        target = messaging.Target(topic=self.topic, server=self.host)
+        # target = messaging.Target(topic=self.topic, server=self.host)
         endpoints = [self.manager]
         endpoints.extend(self.manager.additional_endpoints)
-        serializer = objects_base.VenusObjectSerializer()
-
+        # serializer = objects_base.VenusObjectSerializer()
 
         self.manager.init_host_with_rpc()