Use built-in cached_property on Python 3.8 where possible (#14606)

Functionality is the same, this just removes one dep for Py 3.8+

Author: ashb

Dockerfile.ci

@@ -38,7 +38,7 @@ ENV DEBIAN_FRONTEND=noninteractive LANGUAGE=C.UTF-8 LANG=C.UTF-8 LC_ALL=C.UTF-8
     LC_CTYPE=C.UTF-8 LC_MESSAGES=C.UTF-8
 
 # By increasing this number we can do force build of all dependencies
-ARG DEPENDENCIES_EPOCH_NUMBER="5"
+ARG DEPENDENCIES_EPOCH_NUMBER="6"
 # Increase the value below to force reinstalling of all dependencies
 ENV DEPENDENCIES_EPOCH_NUMBER=${DEPENDENCIES_EPOCH_NUMBER}
 

airflow/models/baseoperator.py

@@ -43,7 +43,11 @@
 
 import attr
 import jinja2
-from cached_property import cached_property
+
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 from dateutil.relativedelta import relativedelta
 from sqlalchemy.orm import Session
 

airflow/operators/bash.py

@@ -18,7 +18,10 @@
 import os
 from typing import Dict, Optional
 
-from cached_property import cached_property
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.exceptions import AirflowException, AirflowSkipException
 from airflow.hooks.subprocess import EXIT_CODE_SKIP, SubprocessHook

airflow/operators/sql.py

@@ -18,7 +18,10 @@
 from distutils.util import strtobool
 from typing import Any, Dict, Iterable, List, Mapping, Optional, SupportsAbs, Union
 
-from cached_property import cached_property
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.exceptions import AirflowException
 from airflow.hooks.base import BaseHook

airflow/providers/amazon/aws/hooks/base_aws.py

@@ -34,7 +34,11 @@
 import botocore.session
 from botocore.config import Config
 from botocore.credentials import ReadOnlyCredentials
-from cached_property import cached_property
+
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 from dateutil.tz import tzlocal
 
 from airflow.exceptions import AirflowException

airflow/providers/amazon/aws/hooks/glue_crawler.py

@@ -18,7 +18,10 @@
 
 from time import sleep
 
-from cached_property import cached_property
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.exceptions import AirflowException
 from airflow.providers.amazon.aws.hooks.base_aws import AwsBaseHook

airflow/providers/amazon/aws/log/cloudwatch_task_handler.py

@@ -17,7 +17,11 @@
 # under the License.
 
 import watchtower
-from cached_property import cached_property
+
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.configuration import conf
 from airflow.utils.log.file_task_handler import FileTaskHandler

airflow/providers/amazon/aws/log/s3_task_handler.py

@@ -17,7 +17,10 @@
 # under the License.
 import os
 
-from cached_property import cached_property
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.configuration import conf
 from airflow.utils.log.file_task_handler import FileTaskHandler

airflow/providers/amazon/aws/operators/athena.py

@@ -19,7 +19,10 @@
 from typing import Any, Dict, Optional
 from uuid import uuid4
 
-from cached_property import cached_property
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.models import BaseOperator
 from airflow.providers.amazon.aws.hooks.athena import AWSAthenaHook

airflow/providers/amazon/aws/operators/glue_crawler.py

@@ -16,7 +16,10 @@
 # specific language governing permissions and limitations
 # under the License.
 
-from cached_property import cached_property
+try:
+    from functools import cached_property
+except ImportError:
+    from cached_property import cached_property
 
 from airflow.models import BaseOperator
 from airflow.providers.amazon.aws.hooks.glue_crawler import AwsGlueCrawlerHook