You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/04/25 19:23:42 UTC
[airflow] branch main updated: Remove `GCSObjectsWtihPrefixExistenceSensor`
This is an automated email from the ASF dual-hosted git repository.
potiuk 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 27ad3b7827 Remove `GCSObjectsWtihPrefixExistenceSensor`
27ad3b7827 is described below
commit 27ad3b7827c5faa116bf43c5530a3d0928fd252d
Author: eladkal <45...@users.noreply.github.com>
AuthorDate: Sun Apr 17 11:13:53 2022 +0300
Remove `GCSObjectsWtihPrefixExistenceSensor`
---
airflow/providers/google/CHANGELOG.rst | 2 ++
airflow/providers/google/cloud/sensors/gcs.py | 17 -----------------
tests/always/test_project_structure.py | 1 -
3 files changed, 2 insertions(+), 18 deletions(-)
diff --git a/airflow/providers/google/CHANGELOG.rst b/airflow/providers/google/CHANGELOG.rst
index a9516ca684..a83d1ac11c 100644
--- a/airflow/providers/google/CHANGELOG.rst
+++ b/airflow/providers/google/CHANGELOG.rst
@@ -36,6 +36,8 @@ Breaking changes
* ``GoogleDriveToGCSOperator``: Remove ``destination_bucket`` and ``destination_object``. Please use ``bucket_name`` and ``object_name``.
+* ``GCSObjectsWtihPrefixExistenceSensor`` removed. Please use ``GCSObjectsWithPrefixExistenceSensor``.
+
6.8.0
.....
diff --git a/airflow/providers/google/cloud/sensors/gcs.py b/airflow/providers/google/cloud/sensors/gcs.py
index bfc48dedee..225ce5937a 100644
--- a/airflow/providers/google/cloud/sensors/gcs.py
+++ b/airflow/providers/google/cloud/sensors/gcs.py
@@ -19,7 +19,6 @@
import os
import textwrap
-import warnings
from datetime import datetime
from typing import TYPE_CHECKING, Callable, List, Optional, Sequence, Set, Union
@@ -228,22 +227,6 @@ class GCSObjectsWithPrefixExistenceSensor(BaseSensorOperator):
return self._matches
-class GCSObjectsWtihPrefixExistenceSensor(GCSObjectsWithPrefixExistenceSensor):
- """
- This class is deprecated.
- Please use `airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor`.
- """
-
- def __init__(self, *args, **kwargs):
- warnings.warn(
- """This class is deprecated.
- Please use `airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor`.""",
- DeprecationWarning,
- stacklevel=3,
- )
- super().__init__(*args, **kwargs)
-
-
def get_time():
"""
This is just a wrapper of datetime.datetime.now to simplify mocking in the
diff --git a/tests/always/test_project_structure.py b/tests/always/test_project_structure.py
index 6cf994ebe8..bd26944233 100644
--- a/tests/always/test_project_structure.py
+++ b/tests/always/test_project_structure.py
@@ -167,7 +167,6 @@ class TestGoogleProviderProjectStructure(unittest.TestCase):
'.CloudDataTransferServiceS3ToGCSOperator',
'airflow.providers.google.cloud.operators.cloud_storage_transfer_service'
'.CloudDataTransferServiceGCSToGCSOperator',
- 'airflow.providers.google.cloud.sensors.gcs.GCSObjectsWtihPrefixExistenceSensor',
'airflow.providers.google.cloud.operators.dataproc.DataprocSubmitHadoopJobOperator',
'airflow.providers.google.cloud.operators.dataproc.DataprocScaleClusterOperator',
'airflow.providers.google.cloud.operators.dataproc.DataprocSubmitSparkJobOperator',