This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 76ca94d2f2 use `cached_property` from functools in `RdsBaseOperator`
(#33133)
76ca94d2f2 is described below
commit 76ca94d2f23de298bb46668998c227a86b4ecbd0
Author: Niko Oliveira <[email protected]>
AuthorDate: Sat Aug 5 00:58:09 2023 -0700
use `cached_property` from functools in `RdsBaseOperator` (#33133)
---
airflow/providers/amazon/aws/operators/rds.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/amazon/aws/operators/rds.py
b/airflow/providers/amazon/aws/operators/rds.py
index a4a2ac5c33..92e98d7bd6 100644
--- a/airflow/providers/amazon/aws/operators/rds.py
+++ b/airflow/providers/amazon/aws/operators/rds.py
@@ -20,9 +20,9 @@ from __future__ import annotations
import json
import warnings
from datetime import timedelta
+from functools import cached_property
from typing import TYPE_CHECKING, Any, Sequence
-from astroid.decorators import cachedproperty
from mypy_boto3_rds.type_defs import TagTypeDef
from airflow.configuration import conf
@@ -74,7 +74,7 @@ class RdsBaseOperator(BaseOperator):
self._await_interval = 60 # seconds
- @cachedproperty
+ @cached_property
def hook(self) -> RdsHook:
return RdsHook(aws_conn_id=self.aws_conn_id,
region_name=self.region_name, **self.hook_params)
