Skip to content

Commit

Permalink
Replace single quotes by double quotes in all Airflow modules (#33766)
Browse files Browse the repository at this point in the history
  • Loading branch information
hussein-awala authored Aug 26, 2023
1 parent 5a1889a commit cfa5477
Show file tree
Hide file tree
Showing 10 changed files with 1,310 additions and 1,310 deletions.
440 changes: 220 additions & 220 deletions airflow/contrib/hooks/__init__.py

Large diffs are not rendered by default.

1,588 changes: 794 additions & 794 deletions airflow/contrib/operators/__init__.py

Large diffs are not rendered by default.

28 changes: 14 additions & 14 deletions airflow/contrib/secrets/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,27 +30,27 @@
)

__deprecated_classes = {
'aws_secrets_manager': {
'SecretsManagerBackend': 'airflow.providers.amazon.aws.secrets.secrets_manager.SecretsManagerBackend',
"aws_secrets_manager": {
"SecretsManagerBackend": "airflow.providers.amazon.aws.secrets.secrets_manager.SecretsManagerBackend",
},
'aws_systems_manager': {
'SystemsManagerParameterStoreBackend': (
'airflow.providers.amazon.aws.secrets.systems_manager.SystemsManagerParameterStoreBackend'
"aws_systems_manager": {
"SystemsManagerParameterStoreBackend": (
"airflow.providers.amazon.aws.secrets.systems_manager.SystemsManagerParameterStoreBackend"
),
},
'azure_key_vault': {
'AzureKeyVaultBackend': 'airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend',
"azure_key_vault": {
"AzureKeyVaultBackend": "airflow.providers.microsoft.azure.secrets.key_vault.AzureKeyVaultBackend",
},
'gcp_secrets_manager': {
'CloudSecretManagerBackend': (
'airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend'
"gcp_secrets_manager": {
"CloudSecretManagerBackend": (
"airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend"
),
'CloudSecretsManagerBackend': (
'airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend'
"CloudSecretsManagerBackend": (
"airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend"
),
},
'hashicorp_vault': {
'VaultBackend': 'airflow.providers.hashicorp.secrets.vault.VaultBackend',
"hashicorp_vault": {
"VaultBackend": "airflow.providers.hashicorp.secrets.vault.VaultBackend",
},
}
add_deprecated_classes(__deprecated_classes, __name__)
176 changes: 88 additions & 88 deletions airflow/contrib/sensors/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,130 +30,130 @@
)

__deprecated_classes = {
'aws_athena_sensor': {
'AthenaSensor': 'airflow.providers.amazon.aws.sensors.athena.AthenaSensor',
"aws_athena_sensor": {
"AthenaSensor": "airflow.providers.amazon.aws.sensors.athena.AthenaSensor",
},
'aws_glue_catalog_partition_sensor': {
'AwsGlueCatalogPartitionSensor': (
'airflow.providers.amazon.aws.sensors.glue_catalog_partition.GlueCatalogPartitionSensor'
"aws_glue_catalog_partition_sensor": {
"AwsGlueCatalogPartitionSensor": (
"airflow.providers.amazon.aws.sensors.glue_catalog_partition.GlueCatalogPartitionSensor"
),
},
'aws_redshift_cluster_sensor': {
'AwsRedshiftClusterSensor': (
'airflow.providers.amazon.aws.sensors.redshift_cluster.RedshiftClusterSensor'
"aws_redshift_cluster_sensor": {
"AwsRedshiftClusterSensor": (
"airflow.providers.amazon.aws.sensors.redshift_cluster.RedshiftClusterSensor"
),
},
'aws_sqs_sensor': {
'SqsSensor': 'airflow.providers.amazon.aws.sensors.sqs.SqsSensor',
'SQSSensor': 'airflow.providers.amazon.aws.sensors.sqs.SqsSensor',
"aws_sqs_sensor": {
"SqsSensor": "airflow.providers.amazon.aws.sensors.sqs.SqsSensor",
"SQSSensor": "airflow.providers.amazon.aws.sensors.sqs.SqsSensor",
},
'azure_cosmos_sensor': {
'AzureCosmosDocumentSensor': (
'airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor'
"azure_cosmos_sensor": {
"AzureCosmosDocumentSensor": (
"airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor"
),
},
'bash_sensor': {
'STDOUT': 'airflow.sensors.bash.STDOUT',
'BashSensor': 'airflow.sensors.bash.BashSensor',
'Popen': 'airflow.sensors.bash.Popen',
'TemporaryDirectory': 'airflow.sensors.bash.TemporaryDirectory',
'gettempdir': 'airflow.sensors.bash.gettempdir',
"bash_sensor": {
"STDOUT": "airflow.sensors.bash.STDOUT",
"BashSensor": "airflow.sensors.bash.BashSensor",
"Popen": "airflow.sensors.bash.Popen",
"TemporaryDirectory": "airflow.sensors.bash.TemporaryDirectory",
"gettempdir": "airflow.sensors.bash.gettempdir",
},
'bigquery_sensor': {
'BigQueryTableExistenceSensor': (
'airflow.providers.google.cloud.sensors.bigquery.BigQueryTableExistenceSensor'
"bigquery_sensor": {
"BigQueryTableExistenceSensor": (
"airflow.providers.google.cloud.sensors.bigquery.BigQueryTableExistenceSensor"
),
'BigQueryTableSensor': 'airflow.providers.google.cloud.sensors.bigquery.BigQueryTableExistenceSensor',
"BigQueryTableSensor": "airflow.providers.google.cloud.sensors.bigquery.BigQueryTableExistenceSensor",
},
'cassandra_record_sensor': {
'CassandraRecordSensor': 'airflow.providers.apache.cassandra.sensors.record.CassandraRecordSensor',
"cassandra_record_sensor": {
"CassandraRecordSensor": "airflow.providers.apache.cassandra.sensors.record.CassandraRecordSensor",
},
'cassandra_table_sensor': {
'CassandraTableSensor': 'airflow.providers.apache.cassandra.sensors.table.CassandraTableSensor',
"cassandra_table_sensor": {
"CassandraTableSensor": "airflow.providers.apache.cassandra.sensors.table.CassandraTableSensor",
},
'celery_queue_sensor': {
'CeleryQueueSensor': 'airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor',
"celery_queue_sensor": {
"CeleryQueueSensor": "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor",
},
'datadog_sensor': {
'DatadogSensor': 'airflow.providers.datadog.sensors.datadog.DatadogSensor',
"datadog_sensor": {
"DatadogSensor": "airflow.providers.datadog.sensors.datadog.DatadogSensor",
},
'file_sensor': {
'FileSensor': 'airflow.sensors.filesystem.FileSensor',
"file_sensor": {
"FileSensor": "airflow.sensors.filesystem.FileSensor",
},
'ftp_sensor': {
'FTPSensor': 'airflow.providers.ftp.sensors.ftp.FTPSensor',
'FTPSSensor': 'airflow.providers.ftp.sensors.ftp.FTPSSensor',
"ftp_sensor": {
"FTPSensor": "airflow.providers.ftp.sensors.ftp.FTPSensor",
"FTPSSensor": "airflow.providers.ftp.sensors.ftp.FTPSSensor",
},
'gcp_transfer_sensor': {
'CloudDataTransferServiceJobStatusSensor':
'airflow.providers.google.cloud.sensors.cloud_storage_transfer_service.'
'CloudDataTransferServiceJobStatusSensor',
'GCPTransferServiceWaitForJobStatusSensor':
'airflow.providers.google.cloud.sensors.cloud_storage_transfer_service.'
'CloudDataTransferServiceJobStatusSensor',
"gcp_transfer_sensor": {
"CloudDataTransferServiceJobStatusSensor":
"airflow.providers.google.cloud.sensors.cloud_storage_transfer_service."
"CloudDataTransferServiceJobStatusSensor",
"GCPTransferServiceWaitForJobStatusSensor":
"airflow.providers.google.cloud.sensors.cloud_storage_transfer_service."
"CloudDataTransferServiceJobStatusSensor",
},
'gcs_sensor': {
'GCSObjectExistenceSensor': 'airflow.providers.google.cloud.sensors.gcs.GCSObjectExistenceSensor',
'GCSObjectsWithPrefixExistenceSensor': (
'airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor'
"gcs_sensor": {
"GCSObjectExistenceSensor": "airflow.providers.google.cloud.sensors.gcs.GCSObjectExistenceSensor",
"GCSObjectsWithPrefixExistenceSensor": (
"airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor"
),
'GCSObjectUpdateSensor': 'airflow.providers.google.cloud.sensors.gcs.GCSObjectUpdateSensor',
'GCSUploadSessionCompleteSensor': (
'airflow.providers.google.cloud.sensors.gcs.GCSUploadSessionCompleteSensor'
"GCSObjectUpdateSensor": "airflow.providers.google.cloud.sensors.gcs.GCSObjectUpdateSensor",
"GCSUploadSessionCompleteSensor": (
"airflow.providers.google.cloud.sensors.gcs.GCSUploadSessionCompleteSensor"
),
'GoogleCloudStorageObjectSensor': (
'airflow.providers.google.cloud.sensors.gcs.GCSObjectExistenceSensor'
"GoogleCloudStorageObjectSensor": (
"airflow.providers.google.cloud.sensors.gcs.GCSObjectExistenceSensor"
),
'GoogleCloudStorageObjectUpdatedSensor': (
'airflow.providers.google.cloud.sensors.gcs.GCSObjectUpdateSensor'
"GoogleCloudStorageObjectUpdatedSensor": (
"airflow.providers.google.cloud.sensors.gcs.GCSObjectUpdateSensor"
),
'GoogleCloudStoragePrefixSensor': (
'airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor'
"GoogleCloudStoragePrefixSensor": (
"airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor"
),
'GoogleCloudStorageUploadSessionCompleteSensor': (
'airflow.providers.google.cloud.sensors.gcs.GCSUploadSessionCompleteSensor'
"GoogleCloudStorageUploadSessionCompleteSensor": (
"airflow.providers.google.cloud.sensors.gcs.GCSUploadSessionCompleteSensor"
),
},
'imap_attachment_sensor': {
'ImapAttachmentSensor': 'airflow.providers.imap.sensors.imap_attachment.ImapAttachmentSensor',
"imap_attachment_sensor": {
"ImapAttachmentSensor": "airflow.providers.imap.sensors.imap_attachment.ImapAttachmentSensor",
},
'jira_sensor': {
'JiraSensor': 'airflow.providers.atlassian.jira.sensors.jira.JiraSensor',
'JiraTicketSensor': 'airflow.providers.atlassian.jira.sensors.jira.JiraTicketSensor',
"jira_sensor": {
"JiraSensor": "airflow.providers.atlassian.jira.sensors.jira.JiraSensor",
"JiraTicketSensor": "airflow.providers.atlassian.jira.sensors.jira.JiraTicketSensor",
},
'mongo_sensor': {
'MongoSensor': 'airflow.providers.mongo.sensors.mongo.MongoSensor',
"mongo_sensor": {
"MongoSensor": "airflow.providers.mongo.sensors.mongo.MongoSensor",
},
'pubsub_sensor': {
'PubSubPullSensor': 'airflow.providers.google.cloud.sensors.pubsub.PubSubPullSensor',
"pubsub_sensor": {
"PubSubPullSensor": "airflow.providers.google.cloud.sensors.pubsub.PubSubPullSensor",
},
'python_sensor': {
'PythonSensor': 'airflow.sensors.python.PythonSensor',
"python_sensor": {
"PythonSensor": "airflow.sensors.python.PythonSensor",
},
'qubole_sensor': {
'QuboleFileSensor': 'airflow.providers.qubole.sensors.qubole.QuboleFileSensor',
'QubolePartitionSensor': 'airflow.providers.qubole.sensors.qubole.QubolePartitionSensor',
'QuboleSensor': 'airflow.providers.qubole.sensors.qubole.QuboleSensor',
"qubole_sensor": {
"QuboleFileSensor": "airflow.providers.qubole.sensors.qubole.QuboleFileSensor",
"QubolePartitionSensor": "airflow.providers.qubole.sensors.qubole.QubolePartitionSensor",
"QuboleSensor": "airflow.providers.qubole.sensors.qubole.QuboleSensor",
},
'redis_key_sensor': {
'RedisKeySensor': 'airflow.providers.redis.sensors.redis_key.RedisKeySensor',
"redis_key_sensor": {
"RedisKeySensor": "airflow.providers.redis.sensors.redis_key.RedisKeySensor",
},
'redis_pub_sub_sensor': {
'RedisPubSubSensor': 'airflow.providers.redis.sensors.redis_pub_sub.RedisPubSubSensor',
"redis_pub_sub_sensor": {
"RedisPubSubSensor": "airflow.providers.redis.sensors.redis_pub_sub.RedisPubSubSensor",
},
'sagemaker_training_sensor': {
'SageMakerHook': 'airflow.providers.amazon.aws.sensors.sagemaker.SageMakerHook',
'SageMakerTrainingSensor': 'airflow.providers.amazon.aws.sensors.sagemaker.SageMakerTrainingSensor',
"sagemaker_training_sensor": {
"SageMakerHook": "airflow.providers.amazon.aws.sensors.sagemaker.SageMakerHook",
"SageMakerTrainingSensor": "airflow.providers.amazon.aws.sensors.sagemaker.SageMakerTrainingSensor",
},
'sftp_sensor': {
'SFTPSensor': 'airflow.providers.sftp.sensors.sftp.SFTPSensor',
"sftp_sensor": {
"SFTPSensor": "airflow.providers.sftp.sensors.sftp.SFTPSensor",
},
'wasb_sensor': {
'WasbBlobSensor': 'airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor',
'WasbPrefixSensor': 'airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor',
"wasb_sensor": {
"WasbBlobSensor": "airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor",
"WasbPrefixSensor": "airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor",
},
'weekday_sensor': {
'DayOfWeekSensor': 'airflow.sensors.weekday.DayOfWeekSensor',
"weekday_sensor": {
"DayOfWeekSensor": "airflow.sensors.weekday.DayOfWeekSensor",
},
}

Expand Down
4 changes: 2 additions & 2 deletions airflow/contrib/task_runner/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@
)

__deprecated_classes = {
'cgroup_task_runner': {
'CgroupTaskRunner': 'airflow.task.task_runner.cgroup_task_runner.CgroupTaskRunner',
"cgroup_task_runner": {
"CgroupTaskRunner": "airflow.task.task_runner.cgroup_task_runner.CgroupTaskRunner",
},
}

Expand Down
40 changes: 20 additions & 20 deletions airflow/contrib/utils/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,35 +30,35 @@
)

__deprecated_classes = {
'gcp_field_sanitizer': {
'GcpBodyFieldSanitizer': 'airflow.providers.google.cloud.utils.field_sanitizer.GcpBodyFieldSanitizer',
'GcpFieldSanitizerException': (
'airflow.providers.google.cloud.utils.field_sanitizer.GcpFieldSanitizerException'
"gcp_field_sanitizer": {
"GcpBodyFieldSanitizer": "airflow.providers.google.cloud.utils.field_sanitizer.GcpBodyFieldSanitizer",
"GcpFieldSanitizerException": (
"airflow.providers.google.cloud.utils.field_sanitizer.GcpFieldSanitizerException"
),
},
'gcp_field_validator': {
'GcpBodyFieldValidator': 'airflow.providers.google.cloud.utils.field_validator.GcpBodyFieldValidator',
'GcpFieldValidationException': (
'airflow.providers.google.cloud.utils.field_validator.GcpFieldValidationException'
"gcp_field_validator": {
"GcpBodyFieldValidator": "airflow.providers.google.cloud.utils.field_validator.GcpBodyFieldValidator",
"GcpFieldValidationException": (
"airflow.providers.google.cloud.utils.field_validator.GcpFieldValidationException"
),
'GcpValidationSpecificationException': (
'airflow.providers.google.cloud.utils.field_validator.GcpValidationSpecificationException'
"GcpValidationSpecificationException": (
"airflow.providers.google.cloud.utils.field_validator.GcpValidationSpecificationException"
),
},
'mlengine_operator_utils': {
'create_evaluate_ops': (
'airflow.providers.google.cloud.utils.mlengine_operator_utils.create_evaluate_ops'
"mlengine_operator_utils": {
"create_evaluate_ops": (
"airflow.providers.google.cloud.utils.mlengine_operator_utils.create_evaluate_ops"
),
},
'mlengine_prediction_summary': {
'JsonCoder': 'airflow.providers.google.cloud.utils.mlengine_prediction_summary.JsonCoder',
'MakeSummary': 'airflow.providers.google.cloud.utils.mlengine_prediction_summary.MakeSummary',
"mlengine_prediction_summary": {
"JsonCoder": "airflow.providers.google.cloud.utils.mlengine_prediction_summary.JsonCoder",
"MakeSummary": "airflow.providers.google.cloud.utils.mlengine_prediction_summary.MakeSummary",
},
'sendgrid': {
'import_string': 'airflow.utils.module_loading.import_string',
"sendgrid": {
"import_string": "airflow.utils.module_loading.import_string",
},
'weekday': {
'WeekDay': 'airflow.utils.weekday.WeekDay',
"weekday": {
"WeekDay": "airflow.utils.weekday.WeekDay",
},
}

Expand Down
6 changes: 3 additions & 3 deletions airflow/contrib/utils/log/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,9 @@
warnings.warn("This module is deprecated. Please use `airflow.utils.log`.", DeprecationWarning, stacklevel=2)

__deprecated_classes = {
'task_handler_with_custom_formatter': {
'TaskHandlerWithCustomFormatter': (
'airflow.utils.log.task_handler_with_custom_formatter.TaskHandlerWithCustomFormatter'
"task_handler_with_custom_formatter": {
"TaskHandlerWithCustomFormatter": (
"airflow.utils.log.task_handler_with_custom_formatter.TaskHandlerWithCustomFormatter"
),
},
}
Expand Down
Loading

0 comments on commit cfa5477

Please sign in to comment.