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 <sebastian.dau...@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