Fixed name of 20 remaining wrongly named operators. (#8994)

Author: potiuk

BREEZE.rst

@@ -878,7 +878,7 @@ This is the current syntax for  `./breeze <./breeze>`_:
 
         Prepares README.md files for backport packages. You can provide (after --) optional version
         in the form of YYYY.MM.DD, optionally followed by the list of packages to generate readme for.
-        If the first parameter is not formatted as a date, then today is used as version.
+        If the first parameter is not formatted as a date, then today is regenerated.
         If no packages are specified, readme for all packages are generated.
         If no date is specified, current date + 3 days is used (allowing for PMC votes to pass).
 

airflow/contrib/operators/oracle_to_azure_data_lake_transfer.py

@@ -24,7 +24,7 @@
 
 # pylint: disable=unused-import
 from airflow.providers.microsoft.azure.operators.oracle_to_azure_data_lake_transfer import (  # noqa
-    OracleToAzureDataLakeTransfer,
+    OracleToAzureDataLakeTransferOperator,
 )
 
 warnings.warn(

airflow/contrib/operators/oracle_to_oracle_transfer.py

@@ -20,9 +20,25 @@
 import warnings
 
 # pylint: disable=unused-import
-from airflow.providers.oracle.operators.oracle_to_oracle_transfer import OracleToOracleTransfer  # noqa
+from airflow.providers.oracle.operators.oracle_to_oracle_transfer import OracleToOracleTransferOperator
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.oracle.operators.oracle_to_oracle_transfer`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class OracleToOracleTransfer(OracleToOracleTransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.oracle.operators.oracle_to_oracle_transfer.OracleToOracleTransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.oracle.operators.oracle_to_oracle_transfer.OracleToOracleTransferOperator`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/contrib/operators/vertica_to_hive.py

@@ -19,10 +19,25 @@
 
 import warnings
 
-# pylint: disable=unused-import
-from airflow.providers.apache.hive.operators.vertica_to_hive import VerticaToHiveTransfer  # noqa
+from airflow.providers.apache.hive.operators.vertica_to_hive import VerticaToHiveTransferOperator
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.apache.hive.operators.vertica_to_hive`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class VerticaToHiveTransfer(VerticaToHiveTransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.apache.hive.operators.vertica_to_hive.VerticaToHiveTransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.apache.hive.operators.vertica_to_hive.VerticaToHiveTransferOperator`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/contrib/operators/vertica_to_mysql.py

@@ -20,9 +20,25 @@
 import warnings
 
 # pylint: disable=unused-import
-from airflow.providers.mysql.operators.vertica_to_mysql import VerticaToMySqlTransfer  # noqa
+from airflow.providers.mysql.operators.vertica_to_mysql import VerticaToMySqlTransferOperator
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.mysql.operators.vertica_to_mysql`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class VerticaToMySqlTransfer(VerticaToMySqlTransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.mysql.operators.vertica_to_mysql.VerticaToMySqlTransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.mysql.operators.vertica_to_mysql.VerticaToMySqlTransferOperator`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/contrib/sensors/hdfs_sensor.py

@@ -20,9 +20,43 @@
 import warnings
 
 # pylint: disable=unused-import
-from airflow.providers.apache.hdfs.sensors.hdfs import HdfsSensorFolder, HdfsSensorRegex  # noqa
+from airflow.providers.apache.hdfs.sensors.hdfs import HdfsFolderSensor, HdfsRegexSensor
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.apache.hdfs.sensors.hdfs`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+# pylint: disable=too-many-ancestors
+class HdfsSensorFolder(HdfsFolderSensor):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.apache.hdfs.sensors.hdfs.HdfsFolderSensor`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.apache.hdfs.sensors.hdfs.HdfsFolderSensor`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)
+
+
+# pylint: disable=too-many-ancestors
+class HdfsSensorRegex(HdfsRegexSensor):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.apache.hdfs.sensors.hdfs.HdfsRegexSensor`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.apache.hdfs.sensors.hdfs.HdfsRegexSensor`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/operators/google_api_to_s3_transfer.py

@@ -22,11 +22,27 @@
 
 import warnings
 
-# pylint: disable=unused-import
-from airflow.providers.amazon.aws.operators.google_api_to_s3_transfer import GoogleApiToS3Transfer  # noqa
+from airflow.providers.amazon.aws.operators.google_api_to_s3_transfer import GoogleApiToS3TransferOperator
 
 warnings.warn(
     "This module is deprecated. "
     "Please use `airflow.providers.amazon.aws.operators.google_api_to_s3_transfer`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class GoogleApiToS3Transfer(GoogleApiToS3TransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.amazon.aws.operators.google_api_to_s3_transfer.GoogleApiToS3TransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.amazon.aws.operators.""" +
+            "google_api_to_s3_transfer.GoogleApiToS3TransferOperator`.",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/operators/hive_to_druid.py

@@ -20,9 +20,25 @@
 import warnings
 
 # pylint: disable=unused-import
-from airflow.providers.apache.druid.operators.hive_to_druid import HiveToDruidTransfer  # noqa
+from airflow.providers.apache.druid.operators.hive_to_druid import HiveToDruidTransferOperator
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.apache.druid.operators.hive_to_druid`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class HiveToDruidTransfer(HiveToDruidTransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.apache.druid.operators.hive_to_druid.HiveToDruidTransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.apache.druid.operators.hive_to_druid.HiveToDruidTransferOperator`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/operators/hive_to_mysql.py

@@ -20,9 +20,25 @@
 import warnings
 
 # pylint: disable=unused-import
-from airflow.providers.apache.hive.operators.hive_to_mysql import HiveToMySqlTransfer  # noqa
+from airflow.providers.apache.hive.operators.hive_to_mysql import HiveToMySqlTransferOperator
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.apache.hive.operators.hive_to_mysql`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class HiveToMySqlTransfer(HiveToMySqlTransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.apache.hive.operators.hive_to_mysql.HiveToMySqlTransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.apache.hive.operators.hive_to_mysql.HiveToMySqlTransferOperator`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)

airflow/operators/mssql_to_hive.py

@@ -19,10 +19,25 @@
 
 import warnings
 
-# pylint: disable=unused-import
-from airflow.providers.apache.hive.operators.mssql_to_hive import MsSqlToHiveTransfer  # noqa
+from airflow.providers.apache.hive.operators.mssql_to_hive import MsSqlToHiveTransferOperator
 
 warnings.warn(
     "This module is deprecated. Please use `airflow.providers.apache.hive.operators.mssql_to_hive`.",
     DeprecationWarning, stacklevel=2
 )
+
+
+class MsSqlToHiveTransfer(MsSqlToHiveTransferOperator):
+    """
+    This class is deprecated.
+    Please use:
+    `airflow.providers.apache.hive.operators.mssql_to_hive.MsSqlToHiveTransferOperator`."""
+
+    def __init__(self, *args, **kwargs):
+        warnings.warn(
+            """This class is deprecated.
+            Please use
+            `airflow.providers.apache.hive.operators.mssql_to_hive.MsSqlToHiveTransferOperator`.""",
+            DeprecationWarning, stacklevel=2
+        )
+        super().__init__(*args, **kwargs)