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 <[email protected]>
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',

Reply via email to