mgr/cephadm: fix flake8

Signed-off-by: Avan Thakkar <athakkar@redhat.com>

diff --git a/src/cephadm/cephadm b/src/cephadm/cephadm
index c32ccb5afd5e7434638287e7276817d01dc88112..ba342991e1b0c0d657a4ad6e29f4606dd1d30b1b 100755 (executable)
--- a/src/cephadm/cephadm
+++ b/src/cephadm/cephadm
@@ -6329,7 +6329,7 @@ def _parse_ipv6_route(routes: str, ips: str) -> Dict[str, Dict[str, Set[str]]]:
         net = [n for n in r.keys()
                if ipaddress.ip_address(ip) in ipaddress.ip_network(n)]
         if net and iface in r[net[0]]:
-            assert(iface)
+            assert iface
             r[net[0]][iface].add(ip)
 
     return r

diff --git a/src/pybind/mgr/cephadm/services/ingress.py b/src/pybind/mgr/cephadm/services/ingress.py
index cf735798ba7cf64920bdb24454e96e57912ce550..02fd8141d5b52dbcee18d35e89a13a350467a9a2 100644 (file)
--- a/src/pybind/mgr/cephadm/services/ingress.py
+++ b/src/pybind/mgr/cephadm/services/ingress.py
@@ -99,7 +99,7 @@ class IngressService(CephService):
             for rank in range(num_ranks):
                 if rank in by_rank:
                     d = by_rank[rank]
-                    assert(d.ports)
+                    assert d.ports
                     servers.append({
                         'name': f"{spec.backend_service}.{rank}",
                         'ip': d.ip or resolve_ip(self.mgr.inventory.get_addr(str(d.hostname))),

diff --git a/src/pybind/mgr/iostat/module.py b/src/pybind/mgr/iostat/module.py
index 8ec21ca509ca5addfa93db527e5a45d4210e8de1..b101094abc0c65f87e100b341fc3e7207288a18f 100644 (file)
--- a/src/pybind/mgr/iostat/module.py
+++ b/src/pybind/mgr/iostat/module.py
@@ -9,13 +9,13 @@ class Module(MgrModule):
 
     def self_test(self) -> None:
         r = self.get('io_rate')
-        assert('pg_stats_delta' in r)
-        assert('stamp_delta' in r['pg_stats_delta'])
-        assert('stat_sum' in r['pg_stats_delta'])
-        assert('num_read_kb' in r['pg_stats_delta']['stat_sum'])
-        assert('num_write_kb' in r['pg_stats_delta']['stat_sum'])
-        assert('num_write' in r['pg_stats_delta']['stat_sum'])
-        assert('num_read' in r['pg_stats_delta']['stat_sum'])
+        assert 'pg_stats_delta' in r
+        assert 'stamp_delta' in r['pg_stats_delta']
+        assert 'stat_sum' in r['pg_stats_delta']
+        assert 'num_read_kb' in r['pg_stats_delta']['stat_sum']
+        assert 'num_write_kb' in r['pg_stats_delta']['stat_sum']
+        assert 'num_write' in r['pg_stats_delta']['stat_sum']
+        assert 'num_read' in r['pg_stats_delta']['stat_sum']
 
     @CLIReadCommand('iostat', poll=True)
     def iostat(self, width: int = 80, print_header: bool = False) -> HandleCommandResult:

diff --git a/src/tools/cephfs/shell/cephfs-shell b/src/tools/cephfs/shell/cephfs-shell
index 0ef01db75161c4e044b315ab679659ae617e1fde..58884a2750efb0dacb8d3460996958a0ed5df0ec 100755 (executable)
--- a/src/tools/cephfs/shell/cephfs-shell
+++ b/src/tools/cephfs/shell/cephfs-shell
@@ -146,10 +146,10 @@ def get_chunks(file_size):
     chunk_start = 0
     chunk_size = 0x20000  # 131072 bytes, default max ssl buffer size
     while chunk_start + chunk_size < file_size:
-        yield(chunk_start, chunk_size)
+        yield chunk_start, chunk_size
         chunk_start += chunk_size
     final_chunk_size = file_size - chunk_start
-    yield(chunk_start, final_chunk_size)
+    yield chunk_start, final_chunk_size
 
 
 def to_bytes(param):