Merge pull request red-hat-storage#3881 from psathyan/fixBlack

Move to the latest version of black formatter

ceph/ceph.py

@@ -1,4 +1,5 @@
 """This module implements the required foundation data structures for testing."""
+
 import datetime
 import json
 import pickle
@@ -299,9 +300,11 @@ def generate_ansible_inventory(
                     if "pool" in node.hostname:
                         logger.info(node.hostname)
                         devices = node.create_lvm(
-                            devices[0:1]
-                            if not device_to_add
-                            else device_to_add.split(),
+                            (
+                                devices[0:1]
+                                if not device_to_add
+                                else device_to_add.split()
+                            ),
                             num=random.randint(1, 10) if device_to_add else None,
                             check_lvm=False if device_to_add else True,
                         )

ceph/ceph_admin/__init__.py

@@ -7,6 +7,7 @@
 Over here, we create a glue between the CLI and CephCI to allow the QE to write test
 scenarios for verifying and validating cephadm.
 """
+
 from typing import Dict
 
 from cli.utilities.configure import setup_ibm_licence

ceph/ceph_admin/alert_manager.py

@@ -1,4 +1,5 @@
 """Deploy the alert manager service in the cluster via cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/apply.py

@@ -6,6 +6,7 @@
 
 This is a mixin object and can be applied to the supported service classes.
 """
+
 import re
 from typing import Dict
 

ceph/ceph_admin/bootstrap.py

@@ -1,4 +1,5 @@
 """Module that allows QE to interface with cephadm bootstrap CLI."""
+
 import json
 import tempfile
 from distutils.version import LooseVersion
@@ -215,9 +216,9 @@ def bootstrap(self: CephAdmProtocol, config: Dict):
             # an upgrade occurs. This enables us to execute the test in the right
             # context.
             self.config["base_url"] = _details[0]
-            self.config[
-                "container_image"
-            ] = f"{_details[1]}/{_details[2]}:{_details[3]}"
+            self.config["container_image"] = (
+                f"{_details[1]}/{_details[2]}:{_details[3]}"
+            )
             self.cluster.rhcs_version = _rhcs_version
             rhbuild = f"{_rhcs_version}-{_platform}"
             base_url = _details[0]

ceph/ceph_admin/ceph.py

@@ -1,4 +1,5 @@
 """Interface to the base command ceph."""
+
 from ceph.ceph_admin import CephAdmin
 
 

ceph/ceph_admin/cephadm_ansible.py

@@ -5,6 +5,7 @@
 - cephadm-purge-cluster.yaml
 - cephadm-clients.yaml
 """
+
 import re
 
 from ceph.ceph_admin.common import config_dict_to_string

ceph/ceph_admin/cephfs_mirror.py

@@ -1,4 +1,5 @@
 """Manage the CephFS Mirror service via the cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/common.py

@@ -1,4 +1,5 @@
 """Contains common functions that can used across the module."""
+
 from typing import Dict
 
 

ceph/ceph_admin/crash.py

@@ -1,4 +1,5 @@
 """Manage the Crash service via cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/daemon.py

@@ -1,4 +1,5 @@
 """CephADM orchestration Daemon operations."""
+
 from utility.log import Log
 
 from .add import AddMixin

ceph/ceph_admin/dashboard.py

@@ -1,4 +1,5 @@
 """Manage the Ceph Dashboard service via ceph CLI."""
+
 import json
 import tempfile
 from json import loads

ceph/ceph_admin/device.py

@@ -1,4 +1,5 @@
 """CephADM orchestration Device operations."""
+
 from time import sleep
 from typing import Dict, Optional, Tuple
 

ceph/ceph_admin/grafana.py

@@ -1,4 +1,5 @@
 """Manage the Ceph Grafana service via cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/helper.py

@@ -1,6 +1,7 @@
 """
 Contains helper functions that can used across the module.
 """
+
 import json
 import os
 import tempfile

ceph/ceph_admin/host.py

@@ -1,4 +1,5 @@
 """Cephadm orchestration host operations."""
+
 import json
 from copy import deepcopy
 

ceph/ceph_admin/iscsi.py

@@ -1,4 +1,5 @@
 """Module to deploy and manage Ceph's iSCSI service."""
+
 from typing import Dict
 
 from ceph.utils import get_nodes_by_ids

ceph/ceph_admin/ls.py

@@ -1,4 +1,5 @@
 """Module that interfaces with ceph orch ls CLI."""
+
 from typing import Dict, Optional, Tuple
 
 from .common import config_dict_to_string

ceph/ceph_admin/maintenance.py

@@ -12,6 +12,7 @@
 This module is inherited where hosts are placed or exited from maintenance using orchestrator.
 
 """
+
 from json import loads
 from time import sleep
 from typing import Dict

ceph/ceph_admin/manager.py

@@ -1,4 +1,5 @@
 """Perform the manager operations via Ceph's cephadm CLI."""
+
 from json import loads
 
 from .ceph import CephCLI

ceph/ceph_admin/mds.py

@@ -1,4 +1,5 @@
 """Manage MDS service via Ceph's cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/mgr.py

@@ -1,4 +1,5 @@
 """Manage the Manager service via Ceph's cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/mon.py

@@ -1,4 +1,5 @@
 """Manage the Monitor service via cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/nfs.py

@@ -1,4 +1,5 @@
 """Manage the NFS service via the cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/node_exporter.py

@@ -1,4 +1,5 @@
 """Module to deploy Node-Exporter service and individual daemon(s)."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/nvmeof.py

@@ -1,4 +1,5 @@
 """Manage the NVMeoF service via ceph-adm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/orch.py

@@ -3,6 +3,7 @@
 
 Provide the interfaces to ceph orch and in turn manage the orchestration engine.
 """
+
 from datetime import datetime, timedelta
 from json import loads
 from time import sleep

ceph/ceph_admin/osd.py

@@ -1,4 +1,5 @@
 """Manage OSD service via cephadm CLI."""
+
 import json
 from time import sleep
 from typing import Dict

ceph/ceph_admin/pause.py

@@ -10,6 +10,7 @@
 
 This module is inherited where orchestrator operations are paused using pause command.
 """
+
 from typing import Dict
 
 from utility.log import Log

ceph/ceph_admin/prometheus.py

@@ -1,4 +1,5 @@
 """Module to deploy Prometheus service and individual daemon(s)."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/ps.py

@@ -1,4 +1,5 @@
 """Module that interfaces with ceph orch ps CLI."""
+
 from typing import Dict, Optional, Tuple
 
 from .common import config_dict_to_string

ceph/ceph_admin/rbd_mirror.py

@@ -1,4 +1,5 @@
 """Manage the RBD Mirror service via the cephadm CLI."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/registry_login.py

@@ -1,4 +1,5 @@
 """Cephadm registry login CLI Command."""
+
 from copy import deepcopy
 from typing import Dict
 

ceph/ceph_admin/remove.py

@@ -4,6 +4,7 @@
 "ceph orch remove service.name "
 This module inherited where service deleted using "remove" operation.
 """
+
 from typing import Dict
 
 from .common import config_dict_to_string

ceph/ceph_admin/resume.py

@@ -10,6 +10,7 @@
 
 This module is inherited where orchestrator operations are resumed using resume command.
 """
+
 from typing import Dict
 
 from utility.log import Log

ceph/ceph_admin/rgw.py

@@ -1,4 +1,5 @@
 """Module to deploy RGW service and individual daemon(s)."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/shell.py

@@ -1,4 +1,5 @@
 """Interface to cephadm shell CLI."""
+
 from copy import deepcopy
 from typing import Dict, List
 

ceph/ceph_admin/snmp_gateway.py

@@ -1,4 +1,5 @@
 """Module to deploy SNMP-Gateway service and individual daemon(s)."""
+
 from typing import Dict
 
 from .apply import ApplyMixin

ceph/ceph_admin/typing_.py

@@ -1,4 +1,6 @@
+# flake8: noqa
 """Custom typing objects to avoid circular imports."""
+
 from datetime import datetime
 from typing import Dict, List
 
@@ -17,17 +19,13 @@ class CephAdmProtocol(Protocol):
     config: Dict
     installer: CephInstaller
 
-    def read_cephadm_gen_pub_key(self, ssh_key_path=None):
-        ...
+    def read_cephadm_gen_pub_key(self, ssh_key_path=None): ...
 
-    def distribute_cephadm_gen_pub_key(self, ssh_key_path=None, nodes=None):
-        ...
+    def distribute_cephadm_gen_pub_key(self, ssh_key_path=None, nodes=None): ...
 
-    def set_tool_repo(self, repo=None):
-        ...
+    def set_tool_repo(self, repo=None): ...
 
-    def install(self, **kwargs: Dict) -> None:
-        ...
+    def install(self, **kwargs: Dict) -> None: ...
 
     def shell(
         self,
@@ -36,8 +34,7 @@ def shell(
         check_status: bool = True,
         timeout: int = 600,
         long_running: bool = False,
-    ):
-        ...
+    ): ...
 
 
 class OrchProtocol(CephAdmProtocol, Protocol):
@@ -52,36 +49,29 @@ def shell(
         check_status: bool = True,
         timeout: int = 600,
         long_running: bool = False,
-    ):
-        ...
+    ): ...
 
-    def get_role_service(self, service_name: str) -> str:
-        ...
+    def get_role_service(self, service_name: str) -> str: ...
 
-    def get_hosts_by_label(self, label: str) -> List:
-        ...
+    def get_hosts_by_label(self, label: str) -> List: ...
 
     def check_service(
         self,
         service_name: str,
         timeout: int = 300,
         interval: int = 5,
         exist: bool = True,
-    ) -> bool:
-        ...
+    ) -> bool: ...
 
-    def op(self, op: str, config: Dict):
-        ...
+    def op(self, op: str, config: Dict): ...
 
-    def verify_status(self, op: str) -> None:
-        ...
+    def verify_status(self, op: str) -> None: ...
 
     def check_service_restart(
         self,
         service_name: str,
         restart_init_time: datetime,
-    ) -> bool:
-        ...
+    ) -> bool: ...
 
 
 class DaemonProtocol(OrchProtocol, Protocol):

ceph/ceph_admin/upgrade.py

@@ -1,4 +1,5 @@
 """Module that interfaces with ceph orch upgrade CLI."""
+
 from datetime import datetime, timedelta
 from json import loads
 from time import sleep

ceph/nvmegw_cli/common.py

@@ -3,6 +3,7 @@
 - Configure spdk and start spdk.
 - Configure nvme-of targets using control.cli.
 """
+
 from json import loads
 
 from ceph.ceph_admin.common import config_dict_to_string

ceph/nvmeof/gateway.py

@@ -3,6 +3,7 @@
 - Configure spdk and start spdk.
 - Configure nvme-of targets using control.cli.
 """
+
 import re
 
 from ceph.ceph import CephNode

ceph/nvmeof/initiator.py

@@ -1,4 +1,5 @@
 """NVME Initiator."""
+
 from .nvme_cli import NVMeCLI
 
 

ceph/rados/crushtool_workflows.py

@@ -10,6 +10,7 @@
 8. bin file tests. ( stats, bad mappings etc.)
 9. dump and verify bin file contents
 """
+
 import json
 import re