This is an automated email from the ASF dual-hosted git repository.
weilee 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 39dba929bb fix(providers/amazon): alias is_authorized_dataset to
is_authorized_asset (#43470)
39dba929bb is described below
commit 39dba929bbc593e853dc2f106be5b62b739d630c
Author: Wei Lee <[email protected]>
AuthorDate: Tue Oct 29 22:34:07 2024 +0800
fix(providers/amazon): alias is_authorized_dataset to is_authorized_asset
(#43470)
---
.../providers/amazon/aws/auth_manager/aws_auth_manager.py | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git
a/providers/src/airflow/providers/amazon/aws/auth_manager/aws_auth_manager.py
b/providers/src/airflow/providers/amazon/aws/auth_manager/aws_auth_manager.py
index face67c38f..414907961c 100644
---
a/providers/src/airflow/providers/amazon/aws/auth_manager/aws_auth_manager.py
+++
b/providers/src/airflow/providers/amazon/aws/auth_manager/aws_auth_manager.py
@@ -17,6 +17,7 @@
from __future__ import annotations
import argparse
+import warnings
from collections import defaultdict
from functools import cached_property
from typing import TYPE_CHECKING, Container, Sequence, cast
@@ -24,7 +25,7 @@ from typing import TYPE_CHECKING, Container, Sequence, cast
from flask import session, url_for
from airflow.cli.cli_config import CLICommand, DefaultHelpParser, GroupCommand
-from airflow.exceptions import AirflowOptionalProviderFeatureException
+from airflow.exceptions import AirflowOptionalProviderFeatureException,
AirflowProviderDeprecationWarning
from airflow.providers.amazon.aws.auth_manager.avp.entities import AvpEntities
from airflow.providers.amazon.aws.auth_manager.avp.facade import (
AwsAuthManagerAmazonVerifiedPermissionsFacade,
@@ -166,6 +167,16 @@ class AwsAuthManager(BaseAuthManager):
method=method, entity_type=AvpEntities.ASSET, user=user or
self.get_user(), entity_id=asset_uri
)
+ def is_authorized_dataset(
+ self, *, method: ResourceMethod, details: AssetDetails | None = None,
user: BaseUser | None = None
+ ) -> bool:
+ warnings.warn(
+ "is_authorized_dataset will be renamed as is_authorized_asset in
Airflow 3 and will be removed when the minimum Airflow version is set to 3.0
for the amazon provider",
+ AirflowProviderDeprecationWarning,
+ stacklevel=2,
+ )
+ return self.is_authorized_asset(method=method, user=user)
+
def is_authorized_pool(
self, *, method: ResourceMethod, details: PoolDetails | None = None,
user: BaseUser | None = None
) -> bool:
