refactor(cached_property): remove python3.8 backports

this backport isn't needed now that we move to python3.8

sdcm/cluster.py

@@ -30,6 +30,7 @@
 from textwrap import dedent
 from datetime import datetime
 import subprocess
+from functools import cached_property
 
 from invoke.exceptions import UnexpectedExit, Failure, CommandTimedOut
 import yaml
@@ -49,7 +50,7 @@
 from sdcm.utils.distro import Distro
 from sdcm.utils.docker import ContainerManager
 from sdcm.utils.thread import raise_event_on_failure
-from sdcm.utils.decorators import cached_property, retrying, log_run_info
+from sdcm.utils.decorators import retrying, log_run_info
 from sdcm.utils.get_username import get_username
 from sdcm.utils.remotewebbrowser import WebDriverContainerMixin
 from sdcm.utils.version_utils import SCYLLA_VERSION_RE, get_gemini_version

sdcm/cluster_aws.py

@@ -12,6 +12,7 @@
 from textwrap import dedent
 from datetime import datetime
 from distutils.version import LooseVersion  # pylint: disable=no-name-in-module,import-error
+from functools import cached_property
 
 import yaml
 from botocore.exceptions import WaiterError, ClientError
@@ -22,7 +23,7 @@
 from sdcm import ec2_client
 from sdcm.cluster import INSTANCE_PROVISION_ON_DEMAND
 from sdcm.utils.common import list_instances_aws, get_ami_tags
-from sdcm.utils.decorators import retrying, cached_property
+from sdcm.utils.decorators import retrying
 from sdcm.sct_events import SpotTerminationEvent, DbEventsFilter
 from sdcm import wait
 from sdcm.remote import LocalCmdRunner, NETWORK_EXCEPTIONS

sdcm/cluster_docker.py

@@ -19,11 +19,11 @@
 import logging
 import pathlib
 from typing import Optional, Union, Dict
+from functools import cached_property
 
 from sdcm import cluster
 from sdcm.remote import LOCALRUNNER
 from sdcm.utils.docker import get_docker_bridge_gateway, Container, ContainerManager, DockerException
-from sdcm.utils.decorators import cached_property
 
 
 DEFAULT_SCYLLA_DB_IMAGE = "scylladb/scylla-nightly"

sdcm/cluster_gce.py

@@ -16,13 +16,13 @@
 import logging
 from textwrap import dedent
 from typing import Dict
+from functools import cached_property
 
 from libcloud.common.google import GoogleBaseError, ResourceNotFoundError
 
 from sdcm import cluster
 from sdcm.sct_events import SpotTerminationEvent
 from sdcm.utils.common import list_instances_gce, gce_meta_to_dict
-from sdcm.utils.decorators import cached_property
 
 
 SPOT_TERMINATION_CHECK_DELAY = 1

sdcm/logcollector.py

@@ -9,8 +9,9 @@
 import zipfile
 import fnmatch
 import traceback
-import requests
+from functools import cached_property
 
+import requests
 from selenium.webdriver.support.ui import WebDriverWait
 from selenium.webdriver.support import expected_conditions as EC
 from selenium.webdriver.common.by import By
@@ -19,7 +20,7 @@
                                ParallelObject, remove_files, get_builder_by_test_id,
                                get_testrun_dir, search_test_id_in_latest, filter_aws_instances_by_type,
                                filter_gce_instances_by_type, get_sct_root_path)
-from sdcm.utils.decorators import retrying, cached_property
+from sdcm.utils.decorators import retrying
 from sdcm.utils.get_username import get_username
 from sdcm.db_stats import PrometheusDBStats
 from sdcm.remote import RemoteCmdRunner, LocalCmdRunner

sdcm/send_email.py

@@ -7,12 +7,12 @@
 from email.mime.application import MIMEApplication
 from email.mime.multipart import MIMEMultipart
 from email.mime.text import MIMEText
+from functools import cached_property
 
 import jinja2
 
 from sdcm.keystore import KeyStore
 from sdcm.utils.common import list_instances_gce, list_instances_aws, list_resources_docker
-from sdcm.utils.decorators import cached_property
 
 LOGGER = logging.getLogger(__name__)
 

sdcm/utils/auto_ssh.py

@@ -12,8 +12,7 @@
 # Copyright (c) 2020 ScyllaDB
 
 import os
-
-from sdcm.utils.decorators import cached_property
+from functools import cached_property
 
 
 AUTO_SSH_IMAGE = "jnovack/autossh:latest"

sdcm/utils/decorators.py

@@ -15,74 +15,12 @@
 import time
 import logging
 import datetime
-import threading
 from functools import wraps, partial
 
 
 LOGGER = logging.getLogger(__name__)
 
 
-try:
-    from functools import cached_property  # pylint: disable=unused-import,ungrouped-imports
-except ImportError:
-    # Copy/pasted from https://github.com/python/cpython/blob/3.8/Lib/functools.py#L923
-
-    # TODO: remove this code after switching to Python 3.8+
-
-    ################################################################################
-    # cached_property() - computed once per instance, cached as attribute
-    ################################################################################
-
-    _NOT_FOUND = object()
-
-    class cached_property:  # pylint: disable=invalid-name,too-few-public-methods
-        def __init__(self, func):
-            self.func = func
-            self.attrname = None
-            self.__doc__ = func.__doc__
-            self.lock = threading.RLock()
-
-        def __set_name__(self, owner, name):
-            if self.attrname is None:
-                self.attrname = name
-            elif name != self.attrname:
-                raise TypeError(
-                    "Cannot assign the same cached_property to two different names "
-                    f"({self.attrname!r} and {name!r})."
-                )
-
-        def __get__(self, instance, owner=None):
-            if instance is None:
-                return self
-            if self.attrname is None:
-                raise TypeError(
-                    "Cannot use cached_property instance without calling __set_name__ on it.")
-            try:
-                cache = instance.__dict__
-            except AttributeError:  # not all objects have __dict__ (e.g. class defines slots)
-                msg = (
-                    f"No '__dict__' attribute on {type(instance).__name__!r} "
-                    f"instance to cache {self.attrname!r} property."
-                )
-                raise TypeError(msg) from None
-            val = cache.get(self.attrname, _NOT_FOUND)
-            if val is _NOT_FOUND:
-                with self.lock:
-                    # check if another thread filled cache while we awaited lock
-                    val = cache.get(self.attrname, _NOT_FOUND)
-                    if val is _NOT_FOUND:
-                        val = self.func(instance)
-                        try:
-                            cache[self.attrname] = val
-                        except TypeError:
-                            msg = (
-                                f"The '__dict__' attribute on {type(instance).__name__!r} instance "
-                                f"does not support item assignment for caching {self.attrname!r} property."
-                            )
-                            raise TypeError(msg) from None
-            return val
-
-
 class Retry(Exception):
     pass
 

sdcm/utils/remotewebbrowser.py

@@ -14,14 +14,14 @@
 import time
 import logging
 from typing import Optional
+from functools import cached_property
 
 from docker import DockerClient  # pylint: disable=wrong-import-order
 from selenium.webdriver import Remote, ChromeOptions
 
 from sdcm.utils.docker import ContainerManager
 from sdcm.utils.common import get_free_port, wait_for_port
 from sdcm.utils.ssh_agent import SSHAgent
-from sdcm.utils.decorators import cached_property
 
 
 WEB_DRIVER_IMAGE = "selenium/standalone-chrome:latest"