mik-laj commented on a change in pull request #9348:
URL: https://github.com/apache/airflow/pull/9348#discussion_r442772078
##########
File path: tests/test_core_to_contrib.py
##########
@@ -24,1741 +24,8 @@
from parameterized import parameterized
-HOOKS = [
- (
- "airflow.providers.apache.cassandra.hooks.cassandra.CassandraHook",
- "airflow.contrib.hooks.cassandra_hook.CassandraHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.compute.ComputeEngineHook",
- "airflow.contrib.hooks.gcp_compute_hook.GceHook",
- ),
- (
- "airflow.providers.google.common.hooks.base_google.GoogleBaseHook",
- "airflow.contrib.hooks.gcp_api_base_hook.GoogleBaseHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.dataflow.DataflowHook",
- "airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.dataproc.DataprocHook",
- "airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.dlp.CloudDLPHook",
- "airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.functions.CloudFunctionsHook",
- "airflow.contrib.hooks.gcp_function_hook.GcfHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.kms.CloudKMSHook",
- "airflow.contrib.hooks.gcp_kms_hook.GoogleCloudKMSHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.mlengine.MLEngineHook",
- "airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.spanner.SpannerHook",
- "airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook",
- ),
- (
-
"airflow.providers.google.cloud.hooks.speech_to_text.CloudSpeechToTextHook",
- "airflow.contrib.hooks.gcp_speech_to_text_hook.GCPSpeechToTextHook",
- ),
- (
-
"airflow.providers.google.cloud.hooks.text_to_speech.CloudTextToSpeechHook",
- "airflow.contrib.hooks.gcp_text_to_speech_hook.GCPTextToSpeechHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.gcs.GCSHook",
- "airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.cloud_build.CloudBuildHook",
- "airflow.contrib.hooks.gcp_cloud_build_hook.CloudBuildHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.bigtable.BigtableHook",
- "airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.kubernetes_engine.GKEHook",
- "airflow.contrib.hooks.gcp_container_hook.GKEClusterHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.datastore.DatastoreHook",
- "airflow.contrib.hooks.datastore_hook.DatastoreHook",
- ),
- (
-
"airflow.providers.google.cloud.hooks.natural_language.CloudNaturalLanguageHook",
-
"airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.pubsub.PubSubHook",
- "airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.cloud_sql.CloudSQLHook",
- "airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.cloud_sql.CloudSQLDatabaseHook",
- "airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.tasks.CloudTasksHook",
- "airflow.contrib.hooks.gcp_tasks_hook.CloudTasksHook",
- ),
- (
-
"airflow.providers.google.cloud.hooks.cloud_storage_transfer_service.CloudDataTransferServiceHook",
- "airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.translate.CloudTranslateHook",
- "airflow.contrib.hooks.gcp_translate_hook.CloudTranslateHook",
- ),
- (
-
"airflow.providers.google.cloud.hooks.video_intelligence.CloudVideoIntelligenceHook",
-
"airflow.contrib.hooks.gcp_video_intelligence_hook.CloudVideoIntelligenceHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.vision.CloudVisionHook",
- "airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook",
- ),
- (
- "airflow.providers.google.cloud.hooks.bigquery.BigQueryHook",
- "airflow.contrib.hooks.bigquery_hook.BigQueryHook",
- ),
- (
- "airflow.providers.amazon.aws.hooks.athena.AWSAthenaHook",
- "airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook",
- ),
- (
- "airflow.providers.amazon.aws.hooks.datasync.AWSDataSyncHook",
- "airflow.contrib.hooks.aws_datasync_hook.AWSDataSyncHook",
- ),
- (
- "airflow.providers.amazon.aws.hooks.s3.S3Hook",
- "airflow.hooks.S3_hook.S3Hook",
- ),
- (
- "airflow.providers.amazon.aws.hooks.sqs.SQSHook",
- "airflow.contrib.hooks.aws_sqs_hook.SQSHook",
- ),
- (
- "airflow.providers.amazon.aws.hooks.lambda_function.AwsLambdaHook",
- "airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook",
- ),
- (
- "airflow.providers.amazon.aws.hooks.sns.AwsSnsHook",
- "airflow.contrib.hooks.aws_sns_hook.AwsSnsHook",
- ),
- (
- 'airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook',
- 'airflow.contrib.hooks.pinot_hook.PinotDbApiHook',
- ),
- (
- 'airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook',
- 'airflow.contrib.hooks.pinot_hook.PinotAdminHook',
- ),
- (
- 'airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook',
- 'airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook',
- ),
- (
- 'airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook',
- 'airflow.contrib.hooks.spark_sql_hook.SparkSqlHook',
- ),
- (
- 'airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook',
- 'airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook',
- ),
- (
- 'airflow.providers.apache.sqoop.hooks.sqoop.SqoopHook',
- 'airflow.contrib.hooks.sqoop_hook.SqoopHook',
- ),
- (
- 'airflow.providers.apache.druid.hooks.druid.DruidHook',
- 'airflow.hooks.druid_hook.DruidHook',
- ),
- (
- 'airflow.providers.apache.druid.hooks.druid.DruidDbApiHook',
- 'airflow.hooks.druid_hook.DruidDbApiHook',
- ),
- (
- 'airflow.providers.apache.hdfs.hooks.hdfs.HDFSHookException',
- 'airflow.hooks.hdfs_hook.HDFSHookException',
- ),
- (
- 'airflow.providers.apache.hdfs.hooks.hdfs.HDFSHook',
- 'airflow.hooks.hdfs_hook.HDFSHook',
- ),
- (
- 'airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook',
- 'airflow.hooks.hive_hooks.HiveMetastoreHook',
- ),
- (
- 'airflow.providers.apache.hive.hooks.hive.HiveCliHook',
- 'airflow.hooks.hive_hooks.HiveCliHook',
- ),
- (
- 'airflow.providers.apache.hive.hooks.hive.HiveServer2Hook',
- 'airflow.hooks.hive_hooks.HiveServer2Hook',
- ),
- (
- 'airflow.providers.apache.pig.hooks.pig.PigCliHook',
- 'airflow.hooks.pig_hook.PigCliHook',
- ),
- (
- 'airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook',
- 'airflow.hooks.webhdfs_hook.WebHDFSHook',
- ),
- (
- 'airflow.hooks.filesystem.FSHook',
- 'airflow.contrib.hooks.fs_hook.FSHook',
- ),
- (
-
'airflow.providers.microsoft.azure.hooks.azure_container_instance.AzureContainerInstanceHook',
-
'airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook',
- ),
- (
-
'airflow.providers.microsoft.azure.hooks.azure_container_registry.AzureContainerRegistryHook',
-
'airflow.contrib.hooks.azure_container_registry_hook.AzureContainerRegistryHook',
- ),
- (
-
'airflow.providers.microsoft.azure.hooks.azure_container_volume.AzureContainerVolumeHook',
-
'airflow.contrib.hooks.azure_container_volume_hook.AzureContainerVolumeHook',
- ),
- (
-
'airflow.providers.microsoft.azure.hooks.azure_cosmos.AzureCosmosDBHook',
- 'airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook',
- ),
- (
-
'airflow.providers.microsoft.azure.hooks.azure_fileshare.AzureFileShareHook',
- 'airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook',
- ),
- (
- 'airflow.providers.microsoft.azure.hooks.wasb.WasbHook',
- 'airflow.contrib.hooks.wasb_hook.WasbHook',
- ),
- (
- 'airflow.providers.amazon.aws.hooks.glue_catalog.AwsGlueCatalogHook',
- 'airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook',
- ),
- (
- 'airflow.providers.amazon.aws.hooks.logs.AwsLogsHook',
- 'airflow.contrib.hooks.aws_logs_hook.AwsLogsHook',
- ),
- (
- 'airflow.providers.amazon.aws.hooks.emr.EmrHook',
- 'airflow.contrib.hooks.emr_hook.EmrHook',
- ),
- (
- 'airflow.providers.amazon.aws.hooks.sagemaker.SageMakerHook',
- 'airflow.contrib.hooks.sagemaker_hook.SageMakerHook',
-
- ),
- (
- 'airflow.providers.mongo.hooks.mongo.MongoHook',
- 'airflow.contrib.hooks.mongo_hook.MongoHook',
- ),
- (
- 'airflow.providers.openfaas.hooks.openfaas.OpenFaasHook',
- 'airflow.contrib.hooks.openfaas_hook.OpenFaasHook',
- ),
- (
- 'airflow.providers.redis.hooks.redis.RedisHook',
- 'airflow.contrib.hooks.redis_hook.RedisHook',
- ),
- (
- 'airflow.providers.docker.hooks.docker.DockerHook',
- 'airflow.hooks.docker_hook.DockerHook',
- ),
- (
- 'airflow.providers.microsoft.mssql.hooks.mssql.MsSqlHook',
- 'airflow.hooks.mssql_hook.MsSqlHook',
- ),
- (
- 'airflow.providers.mysql.hooks.mysql.MySqlHook',
- 'airflow.hooks.mysql_hook.MySqlHook',
- ),
- (
- 'airflow.providers.oracle.hooks.oracle.OracleHook',
- 'airflow.hooks.oracle_hook.OracleHook',
- ),
- (
- 'airflow.providers.postgres.hooks.postgres.PostgresHook',
- 'airflow.hooks.postgres_hook.PostgresHook',
- ),
- (
- 'airflow.providers.presto.hooks.presto.PrestoHook',
- 'airflow.hooks.presto_hook.PrestoHook',
- ),
- (
- 'airflow.providers.samba.hooks.samba.SambaHook',
- 'airflow.hooks.samba_hook.SambaHook',
- ),
- (
- 'airflow.providers.sqlite.hooks.sqlite.SqliteHook',
- 'airflow.hooks.sqlite_hook.SqliteHook',
- ),
- (
- 'airflow.providers.cloudant.hooks.cloudant.CloudantHook',
- 'airflow.contrib.hooks.cloudant_hook.CloudantHook',
- ),
- (
- 'airflow.providers.databricks.hooks.databricks.DatabricksHook',
- 'airflow.contrib.hooks.databricks_hook.DatabricksHook',
- ),
- (
- 'airflow.providers.databricks.hooks.databricks.DatabricksHook',
- 'airflow.contrib.hooks.databricks_hook.DatabricksHook',
- ),
- (
- 'airflow.providers.datadog.hooks.datadog.DatadogHook',
- 'airflow.contrib.hooks.datadog_hook.DatadogHook',
- ),
- (
- 'airflow.providers.dingding.hooks.dingding.DingdingHook',
- 'airflow.contrib.hooks.dingding_hook.DingdingHook',
- ),
- (
- 'airflow.providers.discord.hooks.discord_webhook.DiscordWebhookHook',
- 'airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook',
- ),
- (
- 'airflow.providers.google.suite.hooks.drive.GoogleDriveHook',
- 'airflow.contrib.hooks.gdrive_hook.GoogleDriveHook',
- ),
- (
- 'airflow.providers.jenkins.hooks.jenkins.JenkinsHook',
- 'airflow.contrib.hooks.jenkins_hook.JenkinsHook',
- ),
- (
- 'airflow.providers.jira.hooks.jira.JiraHook',
- 'airflow.contrib.hooks.jira_hook.JiraHook',
- ),
- (
- 'airflow.providers.opsgenie.hooks.opsgenie_alert.OpsgenieAlertHook',
- 'airflow.contrib.hooks.opsgenie_alert_hook.OpsgenieAlertHook',
- ),
- (
- 'airflow.providers.pagerduty.hooks.pagerduty.PagerdutyHook',
- 'airflow.contrib.hooks.pagerduty_hook.PagerdutyHook',
- ),
- (
- 'airflow.providers.qubole.hooks.qubole_check.QuboleCheckHook',
- 'airflow.contrib.hooks.qubole_check_hook.QuboleCheckHook',
- ),
- (
- 'airflow.providers.qubole.hooks.qubole.QuboleHook',
- 'airflow.contrib.hooks.qubole_hook.QuboleHook',
- ),
- (
- 'airflow.providers.salesforce.hooks.salesforce.SalesforceHook',
- 'airflow.contrib.hooks.salesforce_hook.SalesforceHook',
- ),
- (
- 'airflow.providers.segment.hooks.segment.SegmentHook',
- 'airflow.contrib.hooks.segment_hook.SegmentHook',
- ),
- (
- 'airflow.providers.slack.hooks.slack_webhook.SlackWebhookHook',
- 'airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook',
- ),
- (
- 'airflow.providers.vertica.hooks.vertica.VerticaHook',
- 'airflow.contrib.hooks.vertica_hook.VerticaHook',
- ),
- (
- 'airflow.providers.slack.hooks.slack.SlackHook',
- 'airflow.hooks.slack_hook.SlackHook',
- ),
- (
- 'airflow.providers.zendesk.hooks.zendesk.ZendeskHook',
- 'airflow.hooks.zendesk_hook.ZendeskHook',
- ),
- (
- 'airflow.providers.ftp.hooks.ftp.FTPSHook',
- 'airflow.contrib.hooks.ftp_hook.FTPSHook',
- ),
- (
- 'airflow.providers.ftp.hooks.ftp.FTPHook',
- 'airflow.contrib.hooks.ftp_hook.FTPHook',
- ),
- (
- 'airflow.providers.imap.hooks.imap.ImapHook',
- 'airflow.contrib.hooks.imap_hook.ImapHook',
- ),
- (
- 'airflow.providers.ssh.hooks.ssh.SSHHook',
- 'airflow.contrib.hooks.ssh_hook.SSHHook',
- ),
- (
- 'airflow.providers.microsoft.winrm.hooks.winrm.WinRMHook',
- 'airflow.contrib.hooks.winrm_hook.WinRMHook',
- ),
- (
- 'airflow.providers.http.hooks.http.HttpHook',
- 'airflow.hooks.http_hook.HttpHook',
- ),
- (
- 'airflow.providers.jdbc.hooks.jdbc.JdbcHook',
- 'airflow.hooks.jdbc_hook.JdbcHook',
- ),
- (
- 'airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook',
- 'airflow.contrib.hooks.aws_hook.AwsHook',
- ),
- (
- 'airflow.providers.amazon.aws.hooks.aws_dynamodb.AwsDynamoDBHook',
- 'airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook',
- ),
- (
- 'airflow.providers.sftp.hooks.sftp.SFTPHook',
- 'airflow.contrib.hooks.sftp_hook.SFTPHook',
- ),
-]
-
-OPERATORS = [
- (
-
"airflow.providers.google.cloud.operators.dataflow.DataflowCreateJavaJobOperator",
- "airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dataflow.DataflowCreatePythonJobOperator",
- "airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dataflow.DataflowTemplatedJobStartOperator",
- "airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.datastore.CloudDatastoreExportEntitiesOperator",
-
"airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.datastore.CloudDatastoreImportEntitiesOperator",
-
"airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigtable.BigtableUpdateClusterOperator",
-
"airflow.contrib.operators.gcp_bigtable_operator.BigtableClusterUpdateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigtable.BigtableCreateInstanceOperator",
-
"airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigtable.BigtableDeleteInstanceOperator",
-
"airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigtable.BigtableCreateTableOperator",
-
"airflow.contrib.operators.gcp_bigtable_operator.BigtableTableCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigtable.BigtableDeleteTableOperator",
-
"airflow.contrib.operators.gcp_bigtable_operator.BigtableTableDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_build.CloudBuildCreateBuildOperator",
-
"airflow.contrib.operators.gcp_cloud_build_operator.CloudBuildCreateBuildOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.compute.ComputeEngineBaseOperator",
- "airflow.contrib.operators.gcp_compute_operator.GceBaseOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.compute"
- ".ComputeEngineInstanceGroupUpdateManagerTemplateOperator",
- "airflow.contrib.operators.gcp_compute_operator."
- "GceInstanceGroupManagerUpdateTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.compute.ComputeEngineStartInstanceOperator",
-
"airflow.contrib.operators.gcp_compute_operator.GceInstanceStartOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.compute.ComputeEngineStopInstanceOperator",
-
"airflow.contrib.operators.gcp_compute_operator.GceInstanceStopOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.compute.ComputeEngineCopyInstanceTemplateOperator",
-
"airflow.contrib.operators.gcp_compute_operator.GceInstanceTemplateCopyOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.compute.ComputeEngineSetMachineTypeOperator",
-
"airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.kubernetes_engine.GKECreateClusterOperator",
-
"airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.kubernetes_engine.GKEDeleteClusterOperator",
-
"airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.kubernetes_engine.GKEStartPodOperator",
- "airflow.contrib.operators.gcp_container_operator.GKEPodOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPCancelDLPJobOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPCancelDLPJobOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPCreateDeidentifyTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateDeidentifyTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPCreateDLPJobOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateDLPJobOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPCreateInspectTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateInspectTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPCreateJobTriggerOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateJobTriggerOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPCreateStoredInfoTypeOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateStoredInfoTypeOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPDeidentifyContentOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeidentifyContentOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteDeidentifyTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteDeidentifyTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteDLPJobOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteDlpJobOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteInspectTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteInspectTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteJobTriggerOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteJobTriggerOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteStoredInfoTypeOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteStoredInfoTypeOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPGetDeidentifyTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetDeidentifyTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPGetDLPJobOperator",
- "airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetDlpJobOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPGetInspectTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetInspectTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPGetDLPJobTriggerOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetJobTripperOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPGetStoredInfoTypeOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetStoredInfoTypeOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPInspectContentOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPInspectContentOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPListDeidentifyTemplatesOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPListDeidentifyTemplatesOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPListDLPJobsOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPListDlpJobsOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPListInfoTypesOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPListInfoTypesOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPListInspectTemplatesOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPListInspectTemplatesOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPListJobTriggersOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPListJobTriggersOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPListStoredInfoTypesOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPListStoredInfoTypesOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPRedactImageOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPRedactImageOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPReidentifyContentOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPReidentifyContentOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateDeidentifyTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateDeidentifyTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateInspectTemplateOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateInspectTemplateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateJobTriggerOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateJobTriggerOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateStoredInfoTypeOperator",
-
"airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateStoredInfoTypeOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.functions.CloudFunctionDeleteFunctionOperator",
-
"airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.functions.CloudFunctionDeployFunctionOperator",
-
"airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.natural_language."
- "CloudNaturalLanguageAnalyzeEntitiesOperator",
- "airflow.contrib.operators.gcp_natural_language_operator."
- "CloudLanguageAnalyzeEntitiesOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.natural_language."
- "CloudNaturalLanguageAnalyzeEntitySentimentOperator",
- "airflow.contrib.operators.gcp_natural_language_operator."
- "CloudLanguageAnalyzeEntitySentimentOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.natural_language."
- "CloudNaturalLanguageAnalyzeSentimentOperator",
- "airflow.contrib.operators.gcp_natural_language_operator."
- "CloudLanguageAnalyzeSentimentOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.natural_language."
- "CloudNaturalLanguageClassifyTextOperator",
-
"airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageClassifyTextOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.spanner.SpannerDeleteDatabaseInstanceOperator",
-
"airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.spanner.SpannerDeployDatabaseInstanceOperator",
-
"airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeployOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.spanner.SpannerQueryDatabaseInstanceOperator",
-
"airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseQueryOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.spanner.SpannerUpdateDatabaseInstanceOperator",
-
"airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseUpdateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.spanner.SpannerDeleteInstanceOperator",
-
"airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.spanner.SpannerDeployInstanceOperator",
-
"airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeployOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service"
- ".CloudDataTransferServiceCreateJobOperator",
-
"airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service"
- ".CloudDataTransferServiceDeleteJobOperator",
-
"airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service"
- ".CloudDataTransferServiceUpdateJobOperator",
-
"airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobUpdateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service."
- "CloudDataTransferServiceCancelOperationOperator",
- "airflow.contrib.operators.gcp_transfer_operator."
- "GcpTransferServiceOperationCancelOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service."
- "CloudDataTransferServiceGetOperationOperator",
- "airflow.contrib.operators.gcp_transfer_operator."
- "GcpTransferServiceOperationGetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service."
- "CloudDataTransferServicePauseOperationOperator",
- "airflow.contrib.operators.gcp_transfer_operator."
- "GcpTransferServiceOperationPauseOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service."
- "CloudDataTransferServiceResumeOperationOperator",
- "airflow.contrib.operators.gcp_transfer_operator."
- "GcpTransferServiceOperationResumeOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service."
- "CloudDataTransferServiceListOperationsOperator",
- "airflow.contrib.operators.gcp_transfer_operator."
- "GcpTransferServiceOperationsListOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.translate.CloudTranslateTextOperator",
-
"airflow.contrib.operators.gcp_translate_operator.CloudTranslateTextOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.translate_speech.CloudTranslateSpeechOperator",
-
"airflow.contrib.operators.gcp_translate_speech_operator.CloudTranslateSpeechOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.video_intelligence."
- "CloudVideoIntelligenceDetectVideoExplicitContentOperator",
- "airflow.contrib.operators.gcp_video_intelligence_operator."
- "CloudVideoIntelligenceDetectVideoExplicitContentOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.video_intelligence."
- "CloudVideoIntelligenceDetectVideoLabelsOperator",
- "airflow.contrib.operators.gcp_video_intelligence_operator."
- "CloudVideoIntelligenceDetectVideoLabelsOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.video_intelligence."
- "CloudVideoIntelligenceDetectVideoShotsOperator",
- "airflow.contrib.operators.gcp_video_intelligence_operator."
- "CloudVideoIntelligenceDetectVideoShotsOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionImageAnnotateOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionAnnotateImageOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionTextDetectOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectDocumentTextOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionDetectImageLabelsOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectImageLabelsOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionDetectImageSafeSearchOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectImageSafeSearchOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionDetectTextOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectTextOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionCreateProductOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionDeleteProductOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionGetProductOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductGetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionCreateProductSetOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionDeleteProductSetOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionGetProductSetOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetGetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionUpdateProductSetOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetUpdateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionUpdateProductOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionProductUpdateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionCreateReferenceImageOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionReferenceImageCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionRemoveProductFromProductSetOperator",
- "airflow.contrib.operators.gcp_vision_operator."
- "CloudVisionRemoveProductFromProductSetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.mlengine.MLEngineStartBatchPredictionJobOperator",
-
"airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.mlengine.MLEngineManageModelOperator",
- "airflow.contrib.operators.mlengine_operator.MLEngineModelOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.mlengine.MLEngineStartTrainingJobOperator",
- "airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.mlengine.MLEngineManageVersionOperator",
- "airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.pubsub.PubSubPublishMessageOperator",
- "airflow.contrib.operators.pubsub_operator.PubSubPublishOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.pubsub.PubSubCreateSubscriptionOperator",
-
"airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.pubsub.PubSubDeleteSubscriptionOperator",
-
"airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.pubsub.PubSubCreateTopicOperator",
- "airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.pubsub.PubSubDeleteTopicOperator",
- "airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocCreateClusterOperator",
-
"airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocDeleteClusterOperator",
-
"airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocScaleClusterOperator",
-
"airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocSubmitHadoopJobOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocSubmitHiveJobOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcHiveOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocJobBaseOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcJobBaseOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocSubmitPigJobOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcPigOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocSubmitPySparkJobOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocSubmitSparkJobOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcSparkOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocSubmitSparkSqlJobOperator",
- "airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocInstantiateInlineWorkflowTemplateOperator",
- "airflow.contrib.operators.dataproc_operator."
- "DataprocWorkflowTemplateInstantiateInlineOperator",
- ),
- (
- "airflow.providers.google.cloud."
- "operators.dataproc.DataprocInstantiateWorkflowTemplateOperator",
- "airflow.contrib.operators.dataproc_operator."
- "DataprocWorkflowTemplateInstantiateOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryCreateEmptyDatasetOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyDatasetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryCreateEmptyTableOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryCreateExternalTableOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryDeleteDatasetOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryGetDatasetOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryGetDatasetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryGetDatasetTablesOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryGetDatasetTablesOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryPatchDatasetOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryPatchDatasetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryUpdateDatasetOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryUpdateDatasetOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryUpsertTableOperator",
-
"airflow.contrib.operators.bigquery_operator.BigQueryUpsertTableOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryCheckOperator",
-
"airflow.contrib.operators.bigquery_check_operator.BigQueryCheckOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryIntervalCheckOperator",
-
"airflow.contrib.operators.bigquery_check_operator.BigQueryIntervalCheckOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryValueCheckOperator",
-
"airflow.contrib.operators.bigquery_check_operator.BigQueryValueCheckOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryGetDataOperator",
- "airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryExecuteQueryOperator",
- "airflow.contrib.operators.bigquery_operator.BigQueryOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.bigquery.BigQueryDeleteTableOperator",
-
"airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.gcs.GCSBucketCreateAclEntryOperator",
-
"airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageBucketCreateAclEntryOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.gcs.GCSObjectCreateAclEntryOperator",
-
"airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageObjectCreateAclEntryOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.gcs.GCSDeleteObjectsOperator",
-
"airflow.contrib.operators.gcs_delete_operator.GoogleCloudStorageDeleteOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.gcs.GCSListObjectsOperator",
-
"airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator",
- ),
- (
- "airflow.providers.google.cloud.operators.gcs.GCSCreateBucketOperator",
-
"airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator",
- ),
- (
- "airflow.providers.amazon.aws.operators.athena.AWSAthenaOperator",
- "airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator",
- ),
- (
- "airflow.providers.amazon.aws.operators.batch.AwsBatchOperator",
- "airflow.contrib.operators.awsbatch_operator.AWSBatchOperator",
- ),
- (
- "airflow.providers.amazon.aws.operators.sqs.SQSPublishOperator",
-
"airflow.contrib.operators.aws_sqs_publish_operator.SQSPublishOperator",
- ),
- (
- "airflow.providers.amazon.aws.operators.sns.SnsPublishOperator",
- "airflow.contrib.operators.sns_publish_operator.SnsPublishOperator",
- ),
- (
- 'airflow.providers.apache.druid.operators.druid.DruidOperator',
- 'airflow.contrib.operators.druid_operator.DruidOperator',
- ),
- (
-
'airflow.providers.apache.spark.operators.spark_jdbc.SparkSubmitOperator',
- 'airflow.contrib.operators.spark_jdbc_operator.SparkSubmitOperator',
- ),
- (
- 'airflow.providers.apache.spark.operators.spark_sql.SparkSqlOperator',
- 'airflow.contrib.operators.spark_sql_operator.SparkSqlOperator',
- ),
- (
-
'airflow.providers.apache.spark.operators.spark_submit.SparkSubmitOperator',
- 'airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator',
- ),
- (
-
'airflow.providers.apache.spark.operators.spark_jdbc.SparkJDBCOperator',
- 'airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator',
- ),
- (
- 'airflow.providers.apache.sqoop.operators.sqoop.SqoopOperator',
- 'airflow.contrib.operators.sqoop_operator.SqoopOperator',
- ),
- (
-
'airflow.providers.apache.druid.operators.druid_check.DruidCheckOperator',
- 'airflow.operators.druid_check_operator.DruidCheckOperator',
- ),
- (
- 'airflow.providers.apache.hive.operators.hive.HiveOperator',
- 'airflow.operators.hive_operator.HiveOperator',
- ),
- (
-
'airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator',
- 'airflow.operators.hive_stats_operator.HiveStatsCollectionOperator',
- ),
- (
- 'airflow.providers.apache.pig.operators.pig.PigOperator',
- 'airflow.operators.pig_operator.PigOperator',
- ),
- (
-
'airflow.providers.microsoft.azure.operators.adls_list.AzureDataLakeStorageListOperator',
-
'airflow.contrib.operators.adls_list_operator.AzureDataLakeStorageListOperator',
- ),
- (
- 'airflow.providers.microsoft.azure.operators'
- '.azure_container_instances.AzureContainerInstancesOperator',
-
'airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator',
- ),
- (
-
'airflow.providers.microsoft.azure.operators.azure_cosmos.AzureCosmosInsertDocumentOperator',
-
'airflow.contrib.operators.azure_cosmos_operator.AzureCosmosInsertDocumentOperator',
- ),
- (
-
'airflow.providers.microsoft.azure.operators.wasb_delete_blob.WasbDeleteBlobOperator',
-
'airflow.contrib.operators.wasb_delete_blob_operator.WasbDeleteBlobOperator',
- ),
- (
- 'airflow.providers.amazon.aws.operators.ecs.ECSOperator',
- 'airflow.contrib.operators.ecs_operator.ECSOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.emr_add_steps.EmrAddStepsOperator',
- 'airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.emr_create_job_flow.EmrCreateJobFlowOperator',
-
'airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.emr_terminate_job_flow.EmrTerminateJobFlowOperator',
-
'airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.s3_copy_object.S3CopyObjectOperator',
-
'airflow.contrib.operators.s3_copy_object_operator.S3CopyObjectOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.s3_delete_objects.S3DeleteObjectsOperator',
-
'airflow.contrib.operators.s3_delete_objects_operator.S3DeleteObjectsOperator',
- ),
- (
- 'airflow.providers.amazon.aws.operators.s3_list.S3ListOperator',
- 'airflow.contrib.operators.s3_list_operator.S3ListOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_base.SageMakerBaseOperator',
-
'airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_endpoint_config.SageMakerEndpointConfigOperator',
-
'airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_endpoint.SageMakerEndpointOperator',
-
'airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_model.SageMakerModelOperator',
-
'airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_training.SageMakerTrainingOperator',
-
'airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_transform.SageMakerTransformOperator',
-
'airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator',
- ),
- (
-
'airflow.providers.amazon.aws.operators.sagemaker_tuning.SageMakerTuningOperator',
-
'airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator',
- ),
- (
- 'airflow.providers.docker.operators.docker_swarm.DockerSwarmOperator',
- 'airflow.contrib.operators.docker_swarm_operator.DockerSwarmOperator',
- ),
- (
-
'airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator',
-
'airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator',
- ),
- (
- 'airflow.providers.redis.operators.redis_publish.RedisPublishOperator',
-
'airflow.contrib.operators.redis_publish_operator.RedisPublishOperator',
- ),
- (
- 'airflow.operators.bash.BashOperator',
- 'airflow.operators.bash_operator.BashOperator',
- ),
- (
- 'airflow.providers.docker.operators.docker.DockerOperator',
- 'airflow.operators.docker_operator.DockerOperator',
- ),
- (
- 'airflow.providers.microsoft.mssql.operators.mssql.MsSqlOperator',
- 'airflow.operators.mssql_operator.MsSqlOperator',
- ),
- (
- 'airflow.providers.mysql.operators.mysql.MySqlOperator',
- 'airflow.operators.mysql_operator.MySqlOperator',
- ),
- (
- 'airflow.providers.oracle.operators.oracle.OracleOperator',
- 'airflow.operators.oracle_operator.OracleOperator',
- ),
- (
- 'airflow.providers.papermill.operators.papermill.PapermillOperator',
- 'airflow.operators.papermill_operator.PapermillOperator',
- ),
- (
- 'airflow.operators.check_operator.CheckOperator',
- 'airflow.operators.presto_check_operator.PrestoCheckOperator',
- ),
- (
- 'airflow.operators.check_operator.IntervalCheckOperator',
- 'airflow.operators.presto_check_operator.PrestoIntervalCheckOperator',
- ),
- (
- 'airflow.operators.check_operator.ValueCheckOperator',
- 'airflow.operators.presto_check_operator.PrestoValueCheckOperator',
- ),
- (
- 'airflow.operators.sql.SQLCheckOperator',
- 'airflow.operators.check_operator.CheckOperator',
- ),
- (
- 'airflow.operators.sql.SQLIntervalCheckOperator',
- 'airflow.operators.check_operator.IntervalCheckOperator',
- ),
- (
- 'airflow.operators.sql.SQLValueCheckOperator',
- 'airflow.operators.check_operator.ValueCheckOperator',
- ),
- (
- 'airflow.operators.sql.SQLThresholdCheckOperator',
- 'airflow.operators.check_operator.ThresholdCheckOperator',
- ),
- (
- 'airflow.operators.sql.BranchSQLOperator',
- 'airflow.operators.sql_branch_operator.BranchSqlOperator',
- ),
- (
- 'airflow.operators.python.BranchPythonOperator',
- 'airflow.operators.python_operator.BranchPythonOperator',
- ),
- (
- 'airflow.operators.python.PythonOperator',
- 'airflow.operators.python_operator.PythonOperator',
- ),
- (
- 'airflow.operators.python.ShortCircuitOperator',
- 'airflow.operators.python_operator.ShortCircuitOperator',
- ),
- (
- 'airflow.operators.python.PythonVirtualenvOperator',
- 'airflow.operators.python_operator.PythonVirtualenvOperator',
- ),
- (
- 'airflow.providers.sqlite.operators.sqlite.SqliteOperator',
- 'airflow.operators.sqlite_operator.SqliteOperator',
- ),
- (
-
'airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator',
-
'airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator',
- ),
- (
-
'airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator',
-
'airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator',
- ),
- (
- 'airflow.providers.dingding.operators.dingding.DingdingOperator',
- 'airflow.contrib.operators.dingding_operator.DingdingOperator',
- ),
- (
-
'airflow.providers.discord.operators.discord_webhook.DiscordWebhookOperator',
-
'airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator',
- ),
- (
-
'airflow.providers.jenkins.operators.jenkins_job_trigger.JenkinsJobTriggerOperator',
-
'airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator',
- ),
- (
-
'airflow.providers.opsgenie.operators.opsgenie_alert.OpsgenieAlertOperator',
-
'airflow.contrib.operators.opsgenie_alert_operator.OpsgenieAlertOperator',
- ),
- (
- 'airflow.providers.qubole.operators.qubole_check.QuboleCheckOperator',
- 'airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator',
- ),
- (
-
'airflow.providers.qubole.operators.qubole_check.QuboleValueCheckOperator',
-
'airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator',
- ),
- (
- 'airflow.providers.qubole.operators.qubole.QuboleOperator',
- 'airflow.contrib.operators.qubole_operator.QuboleOperator',
- ),
- (
-
'airflow.providers.segment.operators.segment_track_event.SegmentTrackEventOperator',
-
'airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator',
- ),
- (
- 'airflow.providers.slack.operators.slack_webhook.SlackWebhookOperator',
-
'airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator',
- ),
- (
- 'airflow.providers.vertica.operators.vertica.VerticaOperator',
- 'airflow.contrib.operators.vertica_operator.VerticaOperator',
- ),
- (
- 'airflow.providers.slack.operators.slack.SlackAPIPostOperator',
- 'airflow.operators.slack_operator.SlackAPIPostOperator',
- ),
- (
- 'airflow.providers.slack.operators.slack.SlackAPIOperator',
- 'airflow.operators.slack_operator.SlackAPIOperator',
- ),
- (
- 'airflow.providers.grpc.operators.grpc.GrpcOperator',
- 'airflow.contrib.operators.grpc_operator.GrpcOperator',
- ),
- (
- 'airflow.providers.ssh.operators.ssh.SSHOperator',
- 'airflow.contrib.operators.ssh_operator.SSHOperator',
- ),
- (
- 'airflow.providers.microsoft.winrm.operators.winrm.WinRMOperator',
- 'airflow.contrib.operators.winrm_operator.WinRMOperator',
- ),
- (
- 'airflow.providers.email.operators.email.EmailOperator',
- 'airflow.operators.email_operator.EmailOperator',
- ),
- (
- 'airflow.providers.http.operators.http.SimpleHttpOperator',
- 'airflow.operators.http_operator.SimpleHttpOperator',
- ),
- (
- 'airflow.providers.jdbc.operators.jdbc.JdbcOperator',
- 'airflow.operators.jdbc_operator.JdbcOperator',
- ),
- (
- 'airflow.providers.sftp.operators.sftp.SFTPOperator',
- 'airflow.contrib.operators.sftp_operator.SFTPOperator',
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLBaseOperator',
- 'airflow.contrib.operators.gcp_sql_operator.CloudSqlBaseOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLCreateInstanceDatabaseOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLCreateInstanceOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLDeleteInstanceDatabaseOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLDeleteInstanceOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDeleteOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLExecuteQueryOperator',
- 'airflow.contrib.operators.gcp_sql_operator.CloudSqlQueryOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLExportInstanceOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceExportOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLImportInstanceOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceImportOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLInstancePatchOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator'
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_sql.CloudSQLPatchInstanceDatabaseOperator',
-
'airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator'
- ),
- (
- 'airflow.providers.jira.operators.jira.JiraOperator',
- 'airflow.contrib.operators.jira_operator.JiraOperator',
- ),
- (
- 'airflow.providers.postgres.operators.postgres.PostgresOperator',
- 'airflow.operators.postgres_operator.PostgresOperator',
- ),
- (
-
"airflow.providers.google.cloud.operators.speech_to_text.CloudSpeechToTextRecognizeSpeechOperator",
-
"airflow.contrib.operators.gcp_speech_to_text_operator.GcpSpeechToTextRecognizeSpeechOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.text_to_speech.CloudTextToSpeechSynthesizeOperator",
-
"airflow.contrib.operators.gcp_text_to_speech_operator.GcpTextToSpeechSynthesizeOperator",
- ),
-]
-
-SECRETS = [
- (
-
"airflow.providers.amazon.aws.secrets.secrets_manager.SecretsManagerBackend",
- "airflow.contrib.secrets.aws_secrets_manager.SecretsManagerBackend",
- ),
- (
-
"airflow.providers.amazon.aws.secrets.systems_manager.SystemsManagerParameterStoreBackend",
-
"airflow.contrib.secrets.aws_systems_manager.SystemsManagerParameterStoreBackend",
- ),
- (
-
"airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend",
-
"airflow.contrib.secrets.gcp_secrets_manager.CloudSecretsManagerBackend",
- ),
- (
- "airflow.providers.hashicorp.secrets.vault.VaultBackend",
- "airflow.contrib.secrets.hashicorp_vault.VaultBackend",
- ),
-]
-
-SENSORS = [
- (
-
"airflow.providers.apache.cassandra.sensors.record.CassandraRecordSensor",
-
"airflow.contrib.sensors.cassandra_record_sensor.CassandraRecordSensor",
- ),
- (
-
"airflow.providers.apache.cassandra.sensors.table.CassandraTableSensor",
- "airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor",
- ),
- (
- 'airflow.providers.datadog.sensors.datadog.DatadogSensor',
- 'airflow.contrib.sensors.datadog_sensor.DatadogSensor',
- ),
- (
-
"airflow.providers.google.cloud.sensors.bigtable.BigtableTableReplicationCompletedSensor",
- "airflow.contrib.operators.gcp_bigtable_operator."
- "BigtableTableWaitForReplicationSensor",
- ),
- (
-
"airflow.providers.google.cloud.sensors.cloud_storage_transfer_service."
- "CloudDataTransferServiceJobStatusSensor",
- "airflow.contrib.sensors.gcp_transfer_sensor."
- "GCPTransferServiceWaitForJobStatusSensor",
- ),
- (
- "airflow.providers.google.cloud.sensors.pubsub.PubSubPullSensor",
- "airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor",
- ),
- (
-
"airflow.providers.google.cloud.sensors.bigquery.BigQueryTableExistenceSensor",
- "airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor",
- ),
- (
- "airflow.providers.google.cloud.sensors.gcs.GCSObjectExistenceSensor",
- "airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor",
- ),
- (
- "airflow.providers.google.cloud.sensors.gcs.GCSObjectUpdateSensor",
-
"airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor",
- ),
- (
-
"airflow.providers.google.cloud.sensors.gcs.GCSObjectsWtihPrefixExistenceSensor",
- "airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor",
- ),
- (
-
"airflow.providers.google.cloud.sensors.gcs.GCSUploadSessionCompleteSensor",
-
"airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageUploadSessionCompleteSensor",
- ),
- (
- "airflow.providers.amazon.aws.sensors.athena.AthenaSensor",
- "airflow.contrib.sensors.aws_athena_sensor.AthenaSensor",
- ),
- (
- "airflow.providers.amazon.aws.sensors.sqs.SQSSensor",
- "airflow.contrib.sensors.aws_sqs_sensor.SQSSensor",
- ),
- (
- 'airflow.providers.apache.hdfs.sensors.hdfs.HdfsFolderSensor',
- 'airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder',
- ),
- (
- 'airflow.providers.apache.hdfs.sensors.hdfs.HdfsRegexSensor',
- 'airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex',
- ),
- (
-
'airflow.providers.apache.hive.sensors.hive_partition.HivePartitionSensor',
- 'airflow.sensors.hive_partition_sensor.HivePartitionSensor',
- ),
- (
-
'airflow.providers.apache.hive.sensors.metastore_partition.MetastorePartitionSensor',
- 'airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor',
- ),
- (
-
'airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor',
- 'airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor',
- ),
- (
- 'airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor',
- 'airflow.sensors.web_hdfs_sensor.WebHdfsSensor',
- ),
- (
- 'airflow.providers.apache.hdfs.sensors.hdfs.HdfsSensor',
- 'airflow.sensors.hdfs_sensor.HdfsSensor',
- ),
- (
- 'airflow.sensors.weekday_sensor.DayOfWeekSensor',
- 'airflow.contrib.sensors.weekday_sensor.DayOfWeekSensor',
- ),
- (
- 'airflow.sensors.filesystem.FileSensor',
- 'airflow.contrib.sensors.file_sensor.FileSensor',
- ),
- (
- 'airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor',
- 'airflow.contrib.sensors.wasb_sensor.WasbBlobSensor',
- ),
- (
- 'airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor',
- 'airflow.contrib.sensors.wasb_sensor.WasbPrefixSensor',
- ),
- (
-
'airflow.providers.amazon.aws.sensors.glue_catalog_partition.AwsGlueCatalogPartitionSensor',
-
'airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor',
- ),
- (
- 'airflow.providers.amazon.aws.sensors.emr_base.EmrBaseSensor',
- 'airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor',
- ),
- (
- 'airflow.providers.amazon.aws.sensors.emr_job_flow.EmrJobFlowSensor',
- 'airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor',
- ),
- (
- 'airflow.providers.amazon.aws.sensors.emr_step.EmrStepSensor',
- 'airflow.contrib.sensors.emr_step_sensor.EmrStepSensor',
- ),
- (
-
'airflow.providers.amazon.aws.sensors.sagemaker_base.SageMakerBaseSensor',
- 'airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor',
- ),
- (
-
'airflow.providers.amazon.aws.sensors.sagemaker_endpoint.SageMakerEndpointSensor',
-
'airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor',
- ),
- (
-
'airflow.providers.amazon.aws.sensors.sagemaker_transform.SageMakerTransformSensor',
-
'airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor',
- ),
- (
-
'airflow.providers.amazon.aws.sensors.sagemaker_tuning.SageMakerTuningSensor',
-
'airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor',
- ),
- (
-
'airflow.providers.amazon.aws.operators.s3_file_transform.S3FileTransformOperator',
- 'airflow.operators.s3_file_transform_operator.S3FileTransformOperator',
- ),
- (
- 'airflow.providers.amazon.aws.sensors.s3_key.S3KeySensor',
- 'airflow.sensors.s3_key_sensor.S3KeySensor',
- ),
- (
- 'airflow.providers.amazon.aws.sensors.s3_prefix.S3PrefixSensor',
- 'airflow.sensors.s3_prefix_sensor.S3PrefixSensor',
- ),
- (
- 'airflow.sensors.bash.BashSensor',
- 'airflow.contrib.sensors.bash_sensor.BashSensor',
- ),
- (
- 'airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor',
- 'airflow.contrib.sensors.celery_queue_sensor.CeleryQueueSensor',
- ),
- (
- 'airflow.providers.mongo.sensors.mongo.MongoSensor',
- 'airflow.contrib.sensors.mongo_sensor.MongoSensor',
- ),
- (
- 'airflow.sensors.python.PythonSensor',
- 'airflow.contrib.sensors.python_sensor.PythonSensor',
- ),
- (
- 'airflow.providers.redis.sensors.redis_key.RedisKeySensor',
- 'airflow.contrib.sensors.redis_key_sensor.RedisKeySensor',
- ),
- (
- 'airflow.providers.redis.sensors.redis_pub_sub.RedisPubSubSensor',
- 'airflow.contrib.sensors.redis_pub_sub_sensor.RedisPubSubSensor',
- ),
- (
- 'airflow.providers.datadog.sensors.datadog.DatadogSensor',
- 'airflow.contrib.sensors.datadog_sensor.DatadogSensor',
- ),
- (
- 'airflow.providers.qubole.sensors.qubole.QuboleSensor',
- 'airflow.contrib.sensors.qubole_sensor.QuboleSensor',
- ),
- (
- 'airflow.providers.qubole.sensors.qubole.QubolePartitionSensor',
- 'airflow.contrib.sensors.qubole_sensor.QubolePartitionSensor',
- ),
- (
- 'airflow.providers.qubole.sensors.qubole.QuboleFileSensor',
- 'airflow.contrib.sensors.qubole_sensor.QuboleFileSensor',
- ),
- (
- 'airflow.providers.ftp.sensors.ftp.FTPSensor',
- 'airflow.contrib.sensors.ftp_sensor.FTPSensor',
- ),
- (
- 'airflow.providers.ftp.sensors.ftp.FTPSSensor',
- 'airflow.contrib.sensors.ftp_sensor.FTPSSensor',
- ),
- (
- 'airflow.providers.imap.sensors.imap_attachment.ImapAttachmentSensor',
- 'airflow.contrib.sensors.imap_attachment_sensor.ImapAttachmentSensor',
- ),
- (
- 'airflow.providers.jira.sensors.jira.JiraSensor',
- 'airflow.contrib.sensors.jira_sensor.JiraSensor',
- ),
- (
- 'airflow.providers.jira.sensors.jira.JiraTicketSensor',
- 'airflow.contrib.sensors.jira_sensor.JiraTicketSensor',
- ),
- (
- 'airflow.providers.http.sensors.http.HttpSensor',
- 'airflow.sensors.http_sensor.HttpSensor',
- ),
- (
- 'airflow.providers.sftp.sensors.sftp.SFTPSensor',
- 'airflow.contrib.sensors.sftp_sensor.SFTPSensor',
- )
-]
-
-TRANSFERS = [
- (
-
"airflow.providers.google.cloud.transfers.local_to_gcs.LocalFilesystemToGCSOperator",
-
"airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.adls_to_gcs.ADLSToGCSOperator",
-
"airflow.contrib.operators.adls_to_gcs.AdlsToGoogleCloudStorageOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.cloud_storage_transfer_service."
- "CloudDataTransferServiceGCSToGCSOperator",
- "airflow.contrib.operators.gcp_transfer_operator."
- "GoogleCloudStorageToGoogleCloudStorageTransferOperator",
- ),
- (
-
"airflow.providers.google.cloud.operators.vision.CloudVisionAddProductToProductSetOperator",
-
"airflow.contrib.operators.gcp_vision_operator.CloudVisionAddProductToProductSetOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.gcs_to_bigquery.GCSToBigQueryOperator",
-
"airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator",
- ),
- (
- "airflow.providers.google.cloud.transfers.gcs_to_gcs.GCSToGCSOperator",
-
"airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator",
- ),
- (
- "airflow.providers.amazon.aws.transfers.gcs_to_s3.GCSToS3Operator",
- "airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.mssql_to_gcs.MSSQLToGCSOperator",
-
"airflow.contrib.operators.mssql_to_gcs.MsSqlToGoogleCloudStorageOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.mysql_to_gcs.MySQLToGCSOperator",
-
"airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.postgres_to_gcs.PostgresToGCSOperator",
- "airflow.contrib.operators.postgres_to_gcs_operator."
- "PostgresToGoogleCloudStorageOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.bigquery_to_bigquery.BigQueryToBigQueryOperator",
-
"airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.bigquery_to_gcs.BigQueryToGCSOperator",
-
"airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.bigquery_to_mysql.BigQueryToMySqlOperator",
-
"airflow.contrib.operators.bigquery_to_mysql_operator.BigQueryToMySqlOperator",
- ),
- (
-
"airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator",
-
"airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator",
- ),
- (
-
'airflow.providers.amazon.aws.transfers.dynamodb_to_s3.DynamoDBToS3Operator',
- 'airflow.contrib.operators.dynamodb_to_s3.DynamoDBToS3Operator',
- ),
- (
-
'airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator',
- 'airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBOperator',
- ),
- (
-
'airflow.providers.amazon.aws.transfers.imap_attachment_to_s3.ImapAttachmentToS3Operator',
-
'airflow.contrib.operators.imap_attachment_to_s3_operator.ImapAttachmentToS3Operator',
- ),
- (
- 'airflow.providers.amazon.aws.transfers.mongo_to_s3.MongoToS3Operator',
- 'airflow.contrib.operators.mongo_to_s3.MongoToS3Operator',
- ),
- (
- 'airflow.providers.amazon.aws.transfers.s3_to_sftp.S3ToSFTPOperator',
- 'airflow.contrib.operators.s3_to_sftp_operator.S3ToSFTPOperator',
- ),
- (
- 'airflow.providers.amazon.aws.transfers.sftp_to_s3.SFTPToS3Operator',
- 'airflow.contrib.operators.sftp_to_s3_operator.SFTPToS3Operator',
- ),
- (
- 'airflow.providers.amazon.aws.transfers.gcs_to_s3.GCSToS3Operator',
- 'airflow.operators.gcs_to_s3.GCSToS3Operator',
- ),
- (
-
'airflow.providers.amazon.aws.transfers.google_api_to_s3.GoogleApiToS3Operator',
- 'airflow.operators.google_api_to_s3_transfer.GoogleApiToS3Transfer',
- ),
- (
-
'airflow.providers.amazon.aws.transfers.redshift_to_s3.RedshiftToS3Operator',
- 'airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer',
- ),
- (
-
'airflow.providers.amazon.aws.transfers.s3_to_redshift.S3ToRedshiftOperator',
- 'airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer',
- ),
- (
-
'airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator',
- 'airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer',
- ),
- (
-
'airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator',
- 'airflow.operators.hive_to_druid.HiveToDruidTransfer',
- ),
- (
-
'airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator',
- 'airflow.operators.hive_to_mysql.HiveToMySqlTransfer',
- ),
- (
-
'airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator',
- 'airflow.operators.mysql_to_hive.MySqlToHiveTransfer',
- ),
- (
- 'airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator',
- 'airflow.operators.s3_to_hive_operator.S3ToHiveTransfer',
- ),
- (
-
'airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator',
- 'airflow.operators.hive_to_samba_operator.HiveToSambaOperator',
- ),
- (
-
'airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator',
- 'airflow.operators.mssql_to_hive.MsSqlToHiveTransfer',
- ),
- (
-
'airflow.providers.microsoft.azure.transfers.file_to_wasb.FileToWasbOperator',
- 'airflow.contrib.operators.file_to_wasb.FileToWasbOperator',
- ),
- (
-
'airflow.providers.google.suite.transfers.gcs_to_gdrive.GCSToGoogleDriveOperator',
-
'airflow.contrib.operators.gcs_to_gdrive_operator.GCSToGoogleDriveOperator',
- ),
- (
- 'airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake'
- '.OracleToAzureDataLakeOperator',
-
'airflow.contrib.operators.oracle_to_azure_data_lake_transfer.OracleToAzureDataLakeOperator',
- ),
- (
-
'airflow.providers.oracle.transfers.oracle_to_oracle.OracleToOracleOperator',
-
'airflow.contrib.operators.oracle_to_oracle_transfer.OracleToOracleTransfer',
- ),
- (
- 'airflow.providers.google.cloud.transfers.s3_to_gcs.S3ToGCSOperator',
- 'airflow.contrib.operators.s3_to_gcs_operator.S3ToGCSOperator',
- ),
- (
-
'airflow.providers.mysql.transfers.vertica_to_mysql.VerticaToMySqlOperator',
- 'airflow.contrib.operators.vertica_to_mysql.VerticaToMySqlTransfer',
- ),
- (
-
'airflow.providers.mysql.transfers.presto_to_mysql.PrestoToMySqlOperator',
- 'airflow.operators.presto_to_mysql.PrestoToMySqlTransfer',
- ),
- (
-
'airflow.providers.google.cloud.operators.cloud_storage_transfer_service'
- '.CloudDataTransferServiceS3ToGCSOperator',
-
'airflow.contrib.operators.s3_to_gcs_transfer_operator.CloudDataTransferServiceS3ToGCSOperator'
- ),
- (
-
'airflow.providers.google.cloud.transfers.cassandra_to_gcs.CassandraToGCSOperator',
-
'airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator',
- ),
-]
-
-ALL = HOOKS + OPERATORS + SECRETS + SENSORS + TRANSFERS
-
-RENAMED_HOOKS = [
- (old_class, new_class)
- for old_class, new_class in HOOKS + OPERATORS + SECRETS + SENSORS
- if old_class.rpartition(".")[2] != new_class.rpartition(".")[2]
-]
+from airflow.models.baseoperator import BaseOperator
+from tests.deprecated_classes import ALL, RENAMED_ALL
Review comment:
I think we should move the full file. Its name is invalid because it
also contains tests for messages that are not part of AIP-21.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
