This is an automated email from the ASF dual-hosted git repository.
taragolis 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 a747aecea2 fix: try002 for provider alibaba (#38787)
a747aecea2 is described below
commit a747aecea2582499e56e24292f033bae7b04e5d0
Author: Sebastian Daum <dau...@mediamarktsaturn.com>
AuthorDate: Sat Apr 6 16:18:49 2024 +0200
fix: try002 for provider alibaba (#38787)
---
airflow/providers/alibaba/cloud/hooks/oss.py | 14 +++++++-------
pyproject.toml | 2 --
2 files changed, 7 insertions(+), 9 deletions(-)
diff --git a/airflow/providers/alibaba/cloud/hooks/oss.py
b/airflow/providers/alibaba/cloud/hooks/oss.py
index cf0e20127d..59b68bd037 100644
--- a/airflow/providers/alibaba/cloud/hooks/oss.py
+++ b/airflow/providers/alibaba/cloud/hooks/oss.py
@@ -338,17 +338,17 @@ class OSSHook(BaseHook):
extra_config = self.oss_conn.extra_dejson
auth_type = extra_config.get("auth_type", None)
if not auth_type:
- raise Exception("No auth_type specified in extra_config. ")
+ raise ValueError("No auth_type specified in extra_config. ")
if auth_type != "AK":
- raise Exception(f"Unsupported auth_type: {auth_type}")
+ raise ValueError(f"Unsupported auth_type: {auth_type}")
oss_access_key_id = extra_config.get("access_key_id", None)
oss_access_key_secret = extra_config.get("access_key_secret", None)
if not oss_access_key_id:
- raise Exception(f"No access_key_id is specified for connection:
{self.oss_conn_id}")
+ raise ValueError(f"No access_key_id is specified for connection:
{self.oss_conn_id}")
if not oss_access_key_secret:
- raise Exception(f"No access_key_secret is specified for
connection: {self.oss_conn_id}")
+ raise ValueError(f"No access_key_secret is specified for
connection: {self.oss_conn_id}")
return oss2.Auth(oss_access_key_id, oss_access_key_secret)
@@ -356,12 +356,12 @@ class OSSHook(BaseHook):
extra_config = self.oss_conn.extra_dejson
auth_type = extra_config.get("auth_type", None)
if not auth_type:
- raise Exception("No auth_type specified in extra_config. ")
+ raise ValueError("No auth_type specified in extra_config. ")
if auth_type != "AK":
- raise Exception(f"Unsupported auth_type: {auth_type}")
+ raise ValueError(f"Unsupported auth_type: {auth_type}")
default_region = extra_config.get("region", None)
if not default_region:
- raise Exception(f"No region is specified for connection:
{self.oss_conn_id}")
+ raise ValueError(f"No region is specified for connection:
{self.oss_conn_id}")
return default_region
diff --git a/pyproject.toml b/pyproject.toml
index f8c3b5a415..d5fe430b34 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -383,8 +383,6 @@ combine-as-imports = true
"airflow/providers/airbyte/hooks/airbyte.py" = ["TRY002"]
"airflow/providers/airbyte/operators/airbyte.py" = ["TRY002"]
"airflow/providers/airbyte/sensors/airbyte.py" = ["TRY002"]
-# alibaba
-"airflow/providers/alibaba/cloud/hooks/oss.py" = ["TRY002"]
# amazon
"airflow/providers/amazon/aws/operators/athena.py" = ["TRY002"]
"airflow/providers/amazon/aws/operators/emr.py" = ["TRY002"]
