23504 - Fixing flake8 x2.

search-api/src/search_api/exceptions/__init__.py

@@ -64,10 +64,11 @@ def __post_init__(self):
 
 
 class DbRecordNotFoundException(BaseExceptionE):
-    """Row not found in database"""
+    """Row not found in database."""
 
     def __init__(self):
-        self.message = "DB record not found"
+        """Return a valid Record Not Found Exception."""
+        self.message = 'DB record not found'
         self.status_code = HTTPStatus.NOT_FOUND
         super().__init__()
 

search-api/src/search_api/resources/__init__.py

@@ -14,7 +14,7 @@
 """Exposes the versioned endpoints."""
 from .constants import EndpointVersionPath
 from .v1 import bus_bp, internal_bp, meta_bp, ops_bp, purchases_bp
-from .v2 import search_bp, payments_bp
+from .v2 import payments_bp, search_bp
 from .version_endpoint import VersionEndpoint
 
 

search-api/src/search_api/resources/v2/__init__.py

@@ -12,5 +12,5 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 """Exposes all of the resource v2 endpoints in Flask-Blueprint style."""
-from .search import bp as search_bp
 from .payments import bp as payments_bp
+from .search import bp as search_bp

search-api/src/search_api/resources/v2/payments/__init__.py

@@ -17,4 +17,5 @@
 from .payments import bp as payments_bp
 
 bp = Blueprint('PAYMENTS', __name__, url_prefix='/payments')  # pylint: disable=invalid-name
+
 bp.register_blueprint(payments_bp)

search-api/src/search_api/resources/v2/payments/payments.py

@@ -22,15 +22,14 @@
 from search_api.exceptions import DbRecordNotFoundException
 from search_api.models import DocumentAccessRequest
 from search_api.services import simple_queue
-# from search_api.services.gcp_auth.auth_service import ensure_authorized_queue_user
-from search_api.services.gcp_auth import auth_service
+from search_api.services.gcp_auth.auth_service import ensure_authorized_queue_user
 
 bp = Blueprint('GCP_LISTENER', __name__, url_prefix='')  # pylint: disable=invalid-name
 
 
 @bp.post('')
 @cross_origin(origin='*')
-@auth_service.ensure_authorized_queue_user
+@ensure_authorized_queue_user
 def gcp_listener():
     """Process the incoming cloud event.
 

search-api/src/search_api/services/__init__.py

@@ -14,6 +14,7 @@
 """This module wraps the calls to external services used by the API."""
 
 from gcp_queue import GcpQueue
+
 from .authz import BASIC_USER, SBC_STAFF, STAFF_ROLE, SYSTEM_ROLE, get_role, is_staff, is_system
 from .business_solr import BusinessSolr
 from .flags import Flags

search-api/src/search_api/services/gcp_auth/auth_service.py

@@ -88,7 +88,7 @@ def verify_jwt(session):
 
 
 def ensure_authorized_queue_user(f):
-    """Ensures the user is authorized to use the queue."""
+    """Ensure the user is authorized to use the queue."""
 
     @functools.wraps(f)
     def decorated_function(*args, **kwargs):