You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ta...@apache.org on 2024/04/06 08:12:16 UTC
(airflow) branch main updated: fix: try002 for provider apache hdfs (#38792)
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 e706416cd5 fix: try002 for provider apache hdfs (#38792)
e706416cd5 is described below
commit e706416cd58c2978a30b2df8d0f09993a2b0c36f
Author: Sebastian Daum <se...@gmail.com>
AuthorDate: Sat Apr 6 10:12:10 2024 +0200
fix: try002 for provider apache hdfs (#38792)
---
airflow/providers/apache/hdfs/hooks/hdfs.py | 4 ++--
airflow/providers/apache/hdfs/sensors/hdfs.py | 6 +++---
pyproject.toml | 3 ---
3 files changed, 5 insertions(+), 8 deletions(-)
diff --git a/airflow/providers/apache/hdfs/hooks/hdfs.py b/airflow/providers/apache/hdfs/hooks/hdfs.py
index aa256dde3b..8c4fe26c2c 100644
--- a/airflow/providers/apache/hdfs/hooks/hdfs.py
+++ b/airflow/providers/apache/hdfs/hooks/hdfs.py
@@ -38,7 +38,7 @@ class HDFSHookException(AirflowException):
"""
def __init__(self, *args, **kwargs):
- raise Exception(_EXCEPTION_MESSAGE)
+ raise RuntimeError(_EXCEPTION_MESSAGE)
class HDFSHook(BaseHook):
@@ -52,4 +52,4 @@ class HDFSHook(BaseHook):
"""
def __init__(self, *args, **kwargs):
- raise Exception(_EXCEPTION_MESSAGE)
+ raise RuntimeError(_EXCEPTION_MESSAGE)
diff --git a/airflow/providers/apache/hdfs/sensors/hdfs.py b/airflow/providers/apache/hdfs/sensors/hdfs.py
index 9e2551c4e8..cabf81b710 100644
--- a/airflow/providers/apache/hdfs/sensors/hdfs.py
+++ b/airflow/providers/apache/hdfs/sensors/hdfs.py
@@ -39,14 +39,14 @@ class HdfsSensor(BaseSensorOperator):
"""
def __init__(self, *args, **kwargs):
- raise Exception(_EXCEPTION_MESSAGE)
+ raise RuntimeError(_EXCEPTION_MESSAGE)
class HdfsRegexSensor(HdfsSensor): # noqa: D101 Ignore missing docstring
def __init__(self, *args, **kwargs):
- raise Exception(_EXCEPTION_MESSAGE)
+ raise RuntimeError(_EXCEPTION_MESSAGE)
class HdfsFolderSensor(HdfsSensor): # noqa: D101 Ignore missing docstring
def __init__(self, *args, **kwargs):
- raise Exception(_EXCEPTION_MESSAGE)
+ raise RuntimeError(_EXCEPTION_MESSAGE)
diff --git a/pyproject.toml b/pyproject.toml
index 1787a96c35..6edc6f9234 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -392,9 +392,6 @@ combine-as-imports = true
"airflow/providers/apache/beam/hooks/beam.py" = ["TRY002"]
# apache.cassandra
"airflow/providers/apache/cassandra/hooks/cassandra.py" = ["TRY002"]
-# apache.hdfs
-"airflow/providers/apache/hdfs/hooks/hdfs.py" = ["TRY002"]
-"airflow/providers/apache/hdfs/sensors/hdfs.py" = ["TRY002"]
# cncf.kubernetes
"airflow/providers/cncf/kubernetes/operators/pod.py" = ["TRY002"]
# common.sql