Remove GCSObjectsWtihPrefixExistenceSensor

apache · Apr 25, 2022 · 27ad3b7 · 27ad3b7
1 parent f956b76
commit 27ad3b7
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 18 deletions.
diff --git 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
@@ -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 @@ def execute(self, context: "Context") -> List[str]:
         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
@@ -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',