pycodestyle fixes

site/cds_rdm/cli.py

@@ -195,7 +195,6 @@ def delete_record(recid):
     A command to delete a record by giving the pid to delete. **This is a temporary solution** until the deletion mechanism is implemented in service layer.
     Usage: invenio cds-admin delete -r <recid>
     """
-
     # Record
     (
         record_pid,

site/cds_rdm/migration/cli.py

@@ -17,11 +17,13 @@
 
 @click.group()
 def migration():
+    """Migration CLI."""
     pass
 
 
 @migration.command()
 def run():
+    """Run."""
     runner = Runner(
         stream_definitions=[
             RecordStreamDefinition,

site/cds_rdm/migration/extract.py

@@ -17,11 +17,14 @@
 
 
 class LegacyExtract(Extract):
+    """LegacyExtract."""
+
     def __init__(self, dirpath):
         """Constructor."""
         self.dirpath = Path(dirpath).absolute()
 
     def run(self):
+        """Run."""
         files = [
             f
             for f in listdir(self.dirpath)
@@ -37,11 +40,14 @@ def run(self):
 
 
 class LegacyUserExtract(Extract):
+    """LegacyUserExtract."""
+
     def __init__(self, filepath):
         """Constructor."""
         self.filepath = Path(filepath).absolute()
 
     def run(self):
+        """Run."""
         with open(self.filepath, "r") as dump_file:
             data = json.load(dump_file)
             with click.progressbar(data) as records:

site/cds_rdm/migration/load.py

@@ -13,6 +13,9 @@
 
 
 class CDSRecordCopyLoad(RDMRecordCopyLoad):
+    """CDSRecordCopyLoad."""
+
     def __init__(self, communities_cache, db_uri, tmp_dir):
+        """Constructor."""
         tmp_dir = Path(tmp_dir).absolute()
         super().__init__(communities_cache, db_uri, tmp_dir)

site/cds_rdm/migration/transform/transform.py

@@ -123,6 +123,8 @@ def transform(self, entry):
 
 
 class CDSToRDMRecordTransform(RDMRecordTransform):
+    """CDSToRDMRecordTransform."""
+
     def _community_id(self, entry, record):
         communities = record.get("communities")
         if communities:

site/cds_rdm/migration/transform/user_transform.py

@@ -1,9 +1,20 @@
+# -*- coding: utf-8 -*-
+#
+# Copyright (C) 2023 CERN.
+#
+# CDS-RDM is free software; you can redistribute it and/or modify it under
+# the terms of the MIT License; see LICENSE file for more details.
+
+"""CDS-RDM transform user."""
+
 from datetime import datetime
 
 from invenio_rdm_migrator.streams.users import UserEntry, UserTransform
 
 
 class CDSUserTransform(UserTransform):
+    """CDSUserTransform."""
+
     def _user(self, entry):
         """Transform the user."""
         return CDSUserEntry().transform(entry)

site/cds_rdm/migration/transform/xml_processing/rules.py

@@ -95,6 +95,7 @@ def creators(self, key, value):
 @for_each_value
 @require(["a"])
 def contributors(self, key, value):
+    """Translates contributors."""
     return creators(self, key, value)
 
 
@@ -125,7 +126,6 @@ def languages(self, key, value):
 @filter_list_values
 def subjects(self, key, value):
     """Translates languages fields."""
-
     _subjects = self.get("subjects", [])
     subject_a = value.get("a")
     subject_e = value.get("e")
@@ -143,4 +143,5 @@ def subjects(self, key, value):
 @model.over("communities", "^980__")
 @require(["a"])
 def communities(self, key, value):
+    """Translates communities."""
     return ["cms-notes"]

site/cds_rdm/oidc.py

@@ -21,6 +21,7 @@
 
 
 def confirm_registration_form(*args, **kwargs):
+    """Confirm form."""
     Form = confirm_register_form_preferences_factory(_security.confirm_register_form)
 
     class _Form(Form):
@@ -71,6 +72,7 @@ def cern_groups_handler(remote, resp):
 
 
 def cern_info_serializer(remote, resp, token_user_info, user_info):
+    """Info serializer."""
     user_info = user_info or {}
 
     email = token_user_info["email"]