Run pyupgrade for 3.8 (#3236)

Run pyupgrade for 3.8.

Author: daveisfera

redis/__init__.py

@@ -1,4 +1,4 @@
-import sys
+from importlib import metadata
 
 from redis import asyncio  # noqa
 from redis.backoff import default_backoff
@@ -36,11 +36,6 @@
 )
 from redis.utils import from_url
 
-if sys.version_info >= (3, 8):
-    from importlib import metadata
-else:
-    import importlib_metadata as metadata
-
 
 def int_or_str(value):
     try:

redis/client.py

@@ -831,7 +831,7 @@ def clean_health_check_responses(self) -> None:
                 else:
                     raise PubSubError(
                         "A non health check response was cleaned by "
-                        "execute_command: {0}".format(response)
+                        "execute_command: {}".format(response)
                     )
             ttl -= 1
 

redis/cluster.py

@@ -1851,8 +1851,7 @@ def _sharded_message_generator(self):
 
     def _pubsubs_generator(self):
         while True:
-            for pubsub in self.node_pubsub_mapping.values():
-                yield pubsub
+            yield from self.node_pubsub_mapping.values()
 
     def get_sharded_message(
         self, ignore_subscribe_messages=False, timeout=0.0, target_node=None

redis/commands/bf/__init__.py

@@ -5,7 +5,7 @@
 from .info import BFInfo, CFInfo, CMSInfo, TDigestInfo, TopKInfo
 
 
-class AbstractBloom(object):
+class AbstractBloom:
     """
     The client allows to interact with RedisBloom and use all of
     it's functionality.

redis/commands/bf/info.py

@@ -1,7 +1,7 @@
 from ..helpers import nativestr
 
 
-class BFInfo(object):
+class BFInfo:
     capacity = None
     size = None
     filterNum = None
@@ -26,7 +26,7 @@ def __getitem__(self, item):
         return getattr(self, item)
 
 
-class CFInfo(object):
+class CFInfo:
     size = None
     bucketNum = None
     filterNum = None
@@ -57,7 +57,7 @@ def __getitem__(self, item):
         return getattr(self, item)
 
 
-class CMSInfo(object):
+class CMSInfo:
     width = None
     depth = None
     count = None
@@ -72,7 +72,7 @@ def __getitem__(self, item):
         return getattr(self, item)
 
 
-class TopKInfo(object):
+class TopKInfo:
     k = None
     width = None
     depth = None
@@ -89,7 +89,7 @@ def __getitem__(self, item):
         return getattr(self, item)
 
 
-class TDigestInfo(object):
+class TDigestInfo:
     compression = None
     capacity = None
     merged_nodes = None

redis/commands/graph/__init__.py

@@ -252,7 +252,7 @@ async def call_procedure(self, procedure, *args, read_only=False, **kwagrs):
         return await self.query(q, read_only=read_only)
 
     async def labels(self):
-        return ((await self.call_procedure(DB_LABELS, read_only=True))).result_set
+        return (await self.call_procedure(DB_LABELS, read_only=True)).result_set
 
     async def property_keys(self):
         return (await self.call_procedure(DB_PROPERTYKEYS, read_only=True)).result_set

redis/commands/json/commands.py

@@ -314,7 +314,7 @@ def set_file(
 
         """
 
-        with open(file_name, "r") as fp:
+        with open(file_name) as fp:
             file_content = loads(fp.read())
 
         return self.set(name, path, file_content, nx=nx, xx=xx, decode_keys=decode_keys)

redis/utils.py

@@ -1,5 +1,4 @@
 import logging
-import sys
 from contextlib import contextmanager
 from functools import wraps
 from typing import Any, Dict, Mapping, Union
@@ -28,10 +27,7 @@
 except ImportError:
     CRYPTOGRAPHY_AVAILABLE = False
 
-if sys.version_info >= (3, 8):
-    from importlib import metadata
-else:
-    import importlib_metadata as metadata
+from importlib import metadata
 
 
 def from_url(url, **kwargs):

tests/ssl_utils.py

@@ -9,6 +9,6 @@ def get_ssl_filename(name):
             os.path.join(root, "..", "dockers", "stunnel", "keys")
         )
         if not os.path.isdir(cert_dir):
-            raise IOError(f"No SSL certificates found. They should be in {cert_dir}")
+            raise OSError(f"No SSL certificates found. They should be in {cert_dir}")
 
     return os.path.join(cert_dir, name)

tests/test_asyncio/compat.py

@@ -4,7 +4,7 @@
 try:
     mock.AsyncMock
 except AttributeError:
-    import mock
+    from unittest import mock
 
 try:
     from contextlib import aclosing